johanels/akvorado
1
0
Fork 0
mirror of https://github.com/akvorado/akvorado.git synced 2025-12-12 06:24:10 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

outlet/clickhouse: update functional test with respect to last commit

Browse Source
This commit is contained in:
Vincent Bernat
2025-11-14 08:24:35 +01:00
parent e0957495d5
commit 20e931eaf3
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
outlet/clickhouse/functional_test.go
View File

@@ -120,6 +120,7 @@ func TestInsert(t *testing.T) {
`flow_per_batch{quantile="0.9"}`: "1", `flow_per_batch{quantile="0.9"}`: "1",
`flow_per_batch{quantile="0.99"}`: "1", `flow_per_batch{quantile="0.99"}`: "1",
`worker_overloaded_total`: "0", `worker_overloaded_total`: "0",
`worker_steady_total`: "0",
`worker_underloaded_total`: "1", // only the first one is "underloaded" `worker_underloaded_total`: "1", // only the first one is "underloaded"
} }
} else if i < 15 { } else if i < 15 {
@@ -130,6 +131,7 @@ func TestInsert(t *testing.T) {
`flow_per_batch{quantile="0.9"}`: "10", `flow_per_batch{quantile="0.9"}`: "10",
`flow_per_batch{quantile="0.99"}`: "10", `flow_per_batch{quantile="0.99"}`: "10",
`worker_overloaded_total`: "1", // full batch size `worker_overloaded_total`: "1", // full batch size
`worker_steady_total`: "0",
`worker_underloaded_total`: "1", `worker_underloaded_total`: "1",
} }
} else if i < 23 { } else if i < 23 {
@@ -140,6 +142,7 @@ func TestInsert(t *testing.T) {
`flow_per_batch{quantile="0.9"}`: "10", `flow_per_batch{quantile="0.9"}`: "10",
`flow_per_batch{quantile="0.99"}`: "10", `flow_per_batch{quantile="0.99"}`: "10",
`worker_overloaded_total`: "1", `worker_overloaded_total`: "1",
`worker_steady_total`: "1",
`worker_underloaded_total`: "1", `worker_underloaded_total`: "1",
} }
} else { } else {
@@ -150,6 +153,7 @@ func TestInsert(t *testing.T) {
`flow_per_batch{quantile="0.9"}`: "10", `flow_per_batch{quantile="0.9"}`: "10",
`flow_per_batch{quantile="0.99"}`: "10", `flow_per_batch{quantile="0.99"}`: "10",
`worker_overloaded_total`: "1", `worker_overloaded_total`: "1",
`worker_steady_total`: "1", // direct flush, do not increase
`worker_underloaded_total`: "1", `worker_underloaded_total`: "1",
} }
} }