github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-31 15:06:26 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-21 15:47:11 +02:00
parent 34b9434682
commit 32c0fd3437
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 0 additions and 150 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

150
lib/logstorage/pipe_stats_test.go
View file

@ -81,116 +81,6 @@ func TestPipeStats(t *testing.T) {
}, },
}) })
f("stats uniq_values(*) as values", [][]Field{
{
{"_msg", `abc`},
{"a", `2`},
{"b", `3`},
},
{
{"_msg", `def`},
{"a", `1`},
},
{},
{
{"a", `2`},
{"b", `54`},
},
{},
}, [][]Field{
{
{"values", `["1","2","3","54","abc","def"]`},
},
})
f("stats uniq_values(*) limit 6 as values", [][]Field{
{
{"_msg", `abc`},
{"a", `2`},
{"b", `3`},
},
{
{"_msg", `def`},
{"a", `1`},
},
{},
{
{"a", `2`},
{"b", `54`},
},
{},
}, [][]Field{
{
{"values", `["1","2","3","54","abc","def"]`},
},
})
f("stats uniq_values(a) as values", [][]Field{
{
{"_msg", `abc`},
{"a", `2`},
{"b", `3`},
},
{
{"_msg", `def`},
{"a", `1`},
},
{},
{
{"a", `2`},
{"b", `54`},
},
{},
}, [][]Field{
{
{"values", `["1","2"]`},
},
})
f("stats uniq_values(a, b, c) as values", [][]Field{
{
{"_msg", `abc`},
{"a", `2`},
{"b", `3`},
},
{
{"_msg", `def`},
{"a", `1`},
},
{},
{
{"a", `2`},
{"b", `54`},
},
{},
}, [][]Field{
{
{"values", `["1","2","3","54"]`},
},
})
f("stats count_empty(*) as rows", [][]Field{
{
{"_msg", `abc`},
{"a", `2`},
{"b", `3`},
},
{
{"_msg", `def`},
{"a", `1`},
},
{},
{
{"a", `2`},
{"b", `54`},
},
{},
}, [][]Field{
{
{"rows", "2"},
},
})
f("stats count(b) as rows", [][]Field{ f("stats count(b) as rows", [][]Field{
{ {
{"_msg", `abc`}, {"_msg", `abc`},
@ -211,26 +101,6 @@ func TestPipeStats(t *testing.T) {
}, },
}) })
f("stats count_empty(b) as rows", [][]Field{
{
{"_msg", `abc`},
{"a", `2`},
{"b", `3`},
},
{
{"_msg", `def`},
{"a", `1`},
},
{
{"a", `2`},
{"b", `54`},
},
}, [][]Field{
{
{"rows", "1"},
},
})
f("stats count(x) as rows", [][]Field{ f("stats count(x) as rows", [][]Field{
{ {
{"_msg", `abc`}, {"_msg", `abc`},
@ -271,26 +141,6 @@ func TestPipeStats(t *testing.T) {
}, },
}) })
f("stats count_empty(x, _msg) as rows", [][]Field{
{
{"_msg", `abc`},
{"a", `2`},
{"b", `3`},
},
{
{"_msg", `def`},
{"a", `1`},
},
{
{"a", `2`},
{"b", `54`},
},
}, [][]Field{
{
{"rows", "1"},
},
})
f("stats by (a) count(*) as rows", [][]Field{ f("stats by (a) count(*) as rows", [][]Field{
{ {
{"_msg", `abc`}, {"_msg", `abc`},