api
attribute
logger= logging.getLogger(f'{__name__.split('.')[0]}')
attribute
tag= 'API'
attribute
STATUS= {-1: 'RUNNING', 0: 'COMPLETED', 1: 'FAILED', signal.SIGINT.value: 'TERMINATED'}
attribute
ABBR= {'pct': 'percentage', 'net': 'network', 'mem': 'memory', 'recv': 'received', 'bytes_': 'bytes/'}
func
make_compat_trigger_v1(settings)
param
settingsReturns
None
func
make_compat_start_v1(config, settings, info)
param
configparam
settingsparam
infoReturns
None
func
make_compat_stop_v1(settings, trace=None)
param
settingsparam
trace= None
Returns
None
func
make_compat_meta_v1(meta, dtype, settings)
param
metaparam
dtypeparam
settingsReturns
None
func
make_compat_monitor_v1(data)
param
dataReturns
None
func
make_compat_num_v1(data, timestamp, step)
param
dataparam
timestampparam
stepReturns
None
func
make_compat_data_v1(data, timestamp, step)
param
dataparam
timestampparam
stepReturns
None
func
make_compat_file_v1(file, timestamp, step)
param
fileparam
timestampparam
stepReturns
None
func
make_compat_storage_v1(f, fl)
param
fparam
flReturns
None
func
make_compat_message_v1(level, message, timestamp, step)
param
levelparam
messageparam
timestampparam
stepReturns
None
func
make_compat_graph_v1(settings, name, nodes)
param
settingsparam
nameparam
nodesReturns
None
func
make_compat_graph_nodes_v1(d, ref, dep=0, p='', r={})
param
dparam
refparam
dep= 0
param
p= ''
param
r= {}
Returns
None
func
make_compat_alert_v1(settings, t, m, n, level, url, **kwargs)
param
settingsparam
tparam
mparam
nparam
levelparam
urlparam
kwargs= {}
Returns
None
func
make_compat_webhook_v1(timestamp, level, title, message, step, url)
param
timestampparam
levelparam
titleparam
messageparam
stepparam
urlReturns
None