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

Added order by in flow sankey

Browse source
This commit is contained in:
Matteo Biscosi 2025-08-11 11:27:46 +02:00
parent 5838ada885
commit f992492445
4 changed files with 23 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

14
scripts/lua/rest/v2/get/asn/sankey.lua
View file

@ -46,9 +46,11 @@ if criteria_as == "ingress_egress_traffic_criteria" then
queries = {
{
select_query = {
"in_iface_index", "in_device", "bytes_sent", "bytes_rcvd"
"in_iface_index", "in_device", "bytes_sent", "bytes_rcvd",
"total_bytes"
},
where_query = {"asn"},
sort_by = {"total_bytes"},
filters = filters,
root = {
formatter = format_utils.formatASN,
@ -57,9 +59,11 @@ if criteria_as == "ingress_egress_traffic_criteria" then
}
}, {
select_query = {
"out_device", "out_iface_index", "bytes_sent", "bytes_rcvd"
"out_device", "out_iface_index", "bytes_sent", "bytes_rcvd",
"total_bytes"
},
where_query = {"asn"},
sort_by = {"total_bytes"},
filters = filters,
root = {
formatter = format_utils.formatASN,
@ -73,12 +77,13 @@ elseif isEmptyString(criteria) or (criteria == "traffic_between_ases") then
{
select_query = {
"src_asn", "src_peer_asn", "dst_peer_asn", "bytes_sent",
"bytes_rcvd"
"bytes_rcvd", "total_bytes"
},
different_from = {nil, "src_asn", "dst_asn"},
rename_key_field = {nil, "src_peer_asn_1", "dst_peer_asn_1"},
skip_flow = {{key = "src_asn", value = "0"}},
where_query = {"dst_asn"},
sort_by = {"total_bytes"},
filters = {
dst_asn = asn,
ifid = ifid,
@ -93,9 +98,10 @@ elseif isEmptyString(criteria) or (criteria == "traffic_between_ases") then
}, {
select_query = {
"src_peer_asn", "dst_peer_asn", "dst_asn", "bytes_sent",
"bytes_rcvd"
"bytes_rcvd", "total_bytes"
},
where_query = {"src_asn"},
sort_by = {"total_bytes"},
different_from = {"src_asn", "dst_asn"},
rename_key_field = {"src_peer_asn_2", "dst_peer_asn_2"},
skip_flow = {{key = "dst_asn", value = 0}},