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
|
#!/usr/bin/lua
local json = require "cjson"
local function interpret_suffix(rate)
if rate ~= nil then
local value = string.sub(rate, 1, -2)
local suffix = string.sub(rate, -1)
if suffix == "K" then return tonumber(value) * 10^3 end
if suffix == "M" then return tonumber(value) * 10^6 end
if suffix == "G" then return tonumber(value) * 10^9 end
end
return rate
end
local function scrape()
local status = json.decode(get_contents("/var/run/bmx7/json/status")).status
local labels = {
id = status.shortId,
name = status.name,
address = status.primaryIp,
revision = status.revision,
}
metric("bmx7_status", "gauge", labels, 1)
metric("bmx7_cpu_usage", "gauge", nil, status.cpu)
metric("bmx7_mem_usage", "gauge", nil, interpret_suffix(status.mem))
local links = json.decode(get_contents("/var/run/bmx7/json/links")).links
local metric_bmx7_rxRate = metric("bmx7_link_rxRate","gauge")
local metric_bmx7_txRate = metric("bmx7_link_txRate","gauge")
for _, link in pairs(links) do
local labels = {
source = status.shortId,
target = link.shortId,
name = link.name,
dev = link.dev
}
metric_bmx7_rxRate(labels, interpret_suffix(link.rxRate))
metric_bmx7_txRate(labels, interpret_suffix(link.txRate))
end
local metric_bmx7_tunIn = metric("bmx7_tunIn", "gauge")
local parameters = json.decode(get_contents("/var/run/bmx7/json/parameters")).OPTIONS
for _, option in pairs(parameters) do
if option.name == "tunIn" then
for _, instance in pairs(option.INSTANCES) do
for _, child_instance in pairs(instance.CHILD_INSTANCES) do
local labels = {
name = instance.value,
network = child_instance.value
}
metric_bmx7_tunIn(labels, 1)
end
end
elseif option.name == "plugin" then
local metric_bmx7_plugin = metric("bmx7_plugin", "gauge")
for _, instance in pairs(option.INSTANCES) do
metric_bmx7_plugin({ name = instance.value }, 1)
end
end
end
end
return { scrape = scrape }
|