vrr/ntopng
2
0
Fork 0
mirror of https://github.com/ntop/ntopng.git synced 2026-04-29 23:49:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Added QoE timeseries and stats into various entities (#8984)

Browse source
This commit is contained in:
Matteo Biscosi 2025-02-26 18:13:05 +01:00
parent 59dead6933
commit c6c47f727e
16 changed files with 234 additions and 101 deletions
Download patch file Download diff file Expand all files Collapse all files

51
scripts/lua/modules/ts_min_dump_utils.lua
View file

@ -138,6 +138,21 @@ function ts_dump.subnet_update_rrds(when, ifstats, verbose)
scoreAsServer = sstats["score.as_server"]
}, when)
-- QoE Stats
if ntop.isEnterpriseL() then
local qoe_list = {}
for id, value in pairs(sstats.qoe or {}) do
local delta = delta_val(interface, "subnet_qoe_stats.".. ifstats.id .. "." .. subnet .. "." .. id, "min", value.num, true)
qoe_list[id] = delta
end
if table.len(qoe_list) > 0 then
qoe_list.ifid = ifstats.id
qoe_list.subnet = subnet
ts_utils.append("subnet:qoe_stats", qoe_list, when)
end
end
if not ifstats.isSampledTraffic then
ts_utils.append("subnet:tcp_retransmissions", {
ifid = ifstats.id,
@ -206,6 +221,42 @@ function ts_dump.iface_update_general_stats(when, ifstats, verbose)
new_flows = ifstats.stats.new_flows
}, when)
-- QoE Stats
if ntop.isEnterpriseL() then
local qoe_list = {}
-- In case of view interface this ts is emtpy, so get the info from the other interfaces
if ifstats.isView then
for ifid, ifname in pairs(interface.getIfNames() or {}) do
interface.select(ifname)
local stats = interface.getStats() or {}
if stats.isViewed then
for id, value in pairs(stats.qoe or {}) do
if not qoe_list[id] then
qoe_list[id] = 0
end
qoe_list[id] = value.num + qoe_list[id]
end
end
end
-- Go back to the view interface
interface.select(ifstats.id)
for id, value in pairs(qoe_list) do
local delta = delta_val(interface, "iface_qoe_stats.".. ifstats.id .. "." .. id, "min", value, true)
qoe_list[id] = delta
end
else
for id, value in pairs(ifstats.qoe or {}) do
local delta = delta_val(interface, "iface_qoe_stats.".. ifstats.id .. "." .. id, "min", value.num, true)
qoe_list[id] = delta
end
end
if table.len(qoe_list) > 0 then
qoe_list.ifid = ifstats.id
ts_utils.append("iface:qoe_stats", qoe_list, when)
end
end
if not ifstats.isViewed then
-- Viewed interfaces don't have hosts, their hosts stay in the view
ts_utils.append("iface:hosts", {