vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-04-30 16:09:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Implemented no exporter/probe activity (#8608)

Browse source
This commit is contained in:
Luca Deri 2024-08-07 17:52:47 +02:00
parent c2cc635bf1
commit 16b5a8ccc1
10 changed files with 176 additions and 62 deletions
Download patch file Download diff file Expand all files Collapse all files

50
scripts/lua/modules/check_definitions/interface/no_exporter_activity.lua
View file

@ -1,50 +0,0 @@
--
-- (C) 2020 - ntop.org
--
local alerts_api = require("alerts_api")
local alert_consts = require "alert_consts"
local checks = require("checks")
local script = {
-- Script category
category = checks.check_categories.internals,
default_enabled = true,
hooks = {},
severity = alert_consts.get_printable_severities().emergency,
gui = {
i18n_title = "checks.no_exporter_activity_title",
i18n_description = "checks.no_exporter_activity_description",
}
}
-- #################################################################
local function check_exporter_activity(params)
if not interface.isZMQInterface() then
return -- Not a zmq interface, skip this check
end
--[[ Sample code for triggering alert:
local exporter = params.entity_info.name .. '@' .. "1.2.3.4"
params.entity_info.name = exporter
local no_exporter_activity_type = alert_consts.alert_types.alert_no_exporter_activity.new(params.entity_info.name)
no_exporter_activity_type:set_info(params)
no_exporter_activity_type:trigger(params.alert_entity, nil, params.cur_alerts)
--]]
-- Engaged alerts should be automatically released on next iteration
--no_exporter_activity_type:release(params.alert_entity, nil, params.cur_alerts)
end
-- #################################################################
script.hooks.min = check_exporter_activity
-- #################################################################
return script

78
scripts/lua/modules/check_definitions/interface/no_probe_or_exporter_activity.lua Normal file
View file

@ -0,0 +1,78 @@
--
-- (C) 2020 - ntop.org
--
local alerts_api = require("alerts_api")
local alert_consts = require "alert_consts"
local checks = require("checks")
local script = {
-- Script category
category = checks.check_categories.internals,
default_enabled = true,
hooks = {},
severity = alert_consts.get_printable_severities().emergency,
gui = {
i18n_title = "checks.no_exporter_activity_title",
i18n_description = "checks.no_exporter_activity_description",
}
}
-- #################################################################
local function check_exporter_activity(params)
local time_limit = os.time() - 60 -- Alert after 1 minute
local debug = false
if not interface.isZMQInterface() then
return -- Not a zmq interface, skip this check
end
local ifstats = interface.getStats()
for interface_id, probes_list in pairs(ifstats.probes or {}) do
for source_id, probe_info in pairs(probes_list or {}) do
if not(probe_info["probe.last_update"] < time_limit) then
if(debug) then tprint("[NOK] Probe ["..probe_info["probe.ip"].."]: "..probe_info["probe.last_update"]) end
if(probe_info["probe.last_update"] < time_limit) then
params.entity_info.name = params.entity_info.name .. '@' .. probe_info["probe.ip"]
local no_probe_activity_type = alert_consts.alert_types.alert_no_probe_activity.new(params.entity_info.name, probe_info["probe.last_update"])
no_probe_activity_type:set_info(params)
no_probe_activity_type:trigger(params.alert_entity, nil, params.cur_alerts)
end
else
-- Probe is ok, let's now check the exporters
if(debug) then tprint("[OK] Probe ["..probe_info["probe.ip"].."]: "..probe_info["probe.last_update"]) end
for ip_addr, exp in pairs(probe_info.exporters) do
if(exp.time_last_used < time_limit) then
if(debug) then tprint("[NOK] Exporter "..ip_addr.."[probe "..probe_info["probe.ip"].."]: "..exp.time_last_used) end
params.entity_info.name = params.entity_info.name .. '@' .. ip_addr
local no_exporter_activity_type = alert_consts.alert_types.alert_no_exporter_activity.new(params.entity_info.name, exp.time_last_used)
no_exporter_activity_type:set_info(params)
no_exporter_activity_type:trigger(params.alert_entity, nil, params.cur_alerts)
else
if(debug) then tprint("[OK] Exporter "..ip_addr.." [probe "..probe_info["probe.ip"].."]: "..exp.time_last_used) end
end
end
end
end
end
-- Engaged alerts should be automatically released on next iteration
--no_exporter_activity_type:release(params.alert_entity, nil, params.cur_alerts)
end
-- #################################################################
script.hooks.min = check_exporter_activity
-- #################################################################
return script