Site stack improvements

This commit is contained in:
Herbert Wolverson 2023-07-14 14:42:56 +00:00
parent 50dfc8f8de
commit 1d2c1807b0
3 changed files with 172 additions and 168 deletions

View File

@ -48,7 +48,7 @@ pub async fn send_site_stack_map(
|> filter(fn: (r) => strings.hasSuffix(v: r[\"node_parents\"], suffix: \"S{}S\" + r[\"node_index\"] + \"S\" )) |> filter(fn: (r) => strings.hasSuffix(v: r[\"node_parents\"], suffix: \"S{}S\" + r[\"node_index\"] + \"S\" ))
|> group(columns: [\"node_name\", \"node_parents\", \"_field\", \"node_index\", \"direction\"]) |> group(columns: [\"node_name\", \"node_parents\", \"_field\", \"node_index\", \"direction\"])
|> {} |> {}
|> yield(name: \"sum\")", |> yield(name: \"last\")",
org.influx_bucket, period.range(), org.key, site_index, period.aggregate_window_sum()); org.influx_bucket, period.range(), org.key, site_index, period.aggregate_window_sum());
//println!("{qs}"); //println!("{qs}");
@ -108,10 +108,14 @@ pub async fn send_site_stack_map(
}); });
result.iter().skip(MAX_HOSTS).for_each(|row| { result.iter().skip(MAX_HOSTS).for_each(|row| {
row.download.iter().enumerate().for_each(|(i, x)| { row.download.iter().enumerate().for_each(|(i, x)| {
if i < others.download.len() {
others.download[i].1 += x.1; others.download[i].1 += x.1;
}
}); });
row.upload.iter().enumerate().for_each(|(i, x)| { row.upload.iter().enumerate().for_each(|(i, x)| {
if i < others.upload.len() {
others.upload[i].1 += x.1; others.upload[i].1 += x.1;
}
}); });
}); });
result.truncate(MAX_HOSTS); result.truncate(MAX_HOSTS);

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long