1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
# -*- coding: utf-8 -*-
# Description:
# Author: Ilya Mashchenko (l2isbad)
import os
PATH = os.getenv('PATH', '/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin').split(':')
CHART_BEGIN = 'BEGIN {0} {1}\n'
CHART_CREATE = "CHART {0} '{1}' '{2}' '{3}' '{4}' '{5}' {6} {7} {8}\n"
DIMENSION_CREATE = "DIMENSION '{0}' '{1}' {2} {3} {4} '{5}'\n"
DIMENSION_SET = "SET '{0}' = {1}\n"
def setdefault_values(config, base_dict):
for key, value in base_dict.items():
config.setdefault(key, value)
return config
def run_and_exit(func):
def wrapper(*args, **kwargs):
func(*args, **kwargs)
exit(1)
return wrapper
def on_try_except_finally(on_except=(None, ), on_finally=(None, )):
except_func = on_except[0]
finally_func = on_finally[0]
def decorator(func):
def wrapper(*args, **kwargs):
try:
func(*args, **kwargs)
except Exception:
if except_func:
except_func(*on_except[1:])
finally:
if finally_func:
finally_func(*on_finally[1:])
return wrapper
return decorator
def static_vars(**kwargs):
def decorate(func):
for k in kwargs:
setattr(func, k, kwargs[k])
return func
return decorate
@on_try_except_finally(on_except=(exit, 1))
def safe_print(*msg):
"""
:param msg:
:return:
"""
print(''.join(msg))
def find_binary(binary):
"""
:param binary: <str>
:return:
"""
for directory in PATH:
binary_name = '/'.join([directory, binary])
if os.path.isfile(binary_name) and os.access(binary_name, os.X_OK):
return binary_name
return None
def read_last_line(f):
with open(f, 'rb') as opened:
opened.seek(-2, 2)
while opened.read(1) != b'\n':
opened.seek(-2, 1)
if opened.tell() == 0:
break
result = opened.readline()
return result.decode()
class OldVersionCompatibility:
def __init__(self):
self._data_stream = str()
def begin(self, type_id, microseconds=0):
"""
:param type_id: <str>
:param microseconds: <str> or <int>: must be a digit
:return:
"""
self._data_stream += CHART_BEGIN.format(type_id, microseconds)
def set(self, dim_id, value):
"""
:param dim_id: <str>
:param value: <int> or <str>: must be a digit
:return:
"""
self._data_stream += DIMENSION_SET.format(dim_id, value)
def end(self):
self._data_stream += 'END\n'
def chart(self, type_id, name='', title='', units='', family='', category='', chart_type='line',
priority='', update_every=''):
"""
:param type_id: <str>
:param name: <str>
:param title: <str>
:param units: <str>
:param family: <str>
:param category: <str>
:param chart_type: <str>
:param priority: <str> or <int>
:param update_every: <str> or <int>
:return:
"""
self._data_stream += CHART_CREATE.format(type_id, name, title, units,
family, category, chart_type,
priority, update_every)
def dimension(self, dim_id, name=None, algorithm="absolute", multiplier=1, divisor=1, hidden=False):
"""
:param dim_id: <str>
:param name: <str> or None
:param algorithm: <str>
:param multiplier: <str> or <int>: must be a digit
:param divisor: <str> or <int>: must be a digit
:param hidden: <str>: literally "hidden" or ""
:return:
"""
self._data_stream += DIMENSION_CREATE.format(dim_id, name or dim_id, algorithm,
multiplier, divisor, hidden or str())
@on_try_except_finally(on_except=(exit, 1))
def commit(self):
print(self._data_stream)
self._data_stream = str()
|
