Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-15 16:30:55 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

app/vmselect/promql: fix tests after 781947a7e2

Browse Source
This commit is contained in:
Aliaksandr Valialkin 2023-07-20 21:25:30 -07:00
parent 939c8b8372
commit a0b7def89d
No known key found for this signature in database
GPG Key ID: A72BEC6CD3D0DED1
1 changed files with 12 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
app/vmselect/promql/exec_test.go
View File

@ -3017,23 +3017,21 @@ func TestExecSuccess(t *testing.T) {
t.Parallel() t.Parallel()
q := `sort_desc(((label_set(time(), "foo", "bar", "__name__", "q1") or label_set(10, "foo", "qwert", "__name__", "q2")) / 2) keep_metric_names)` q := `sort_desc(((label_set(time(), "foo", "bar", "__name__", "q1") or label_set(10, "foo", "qwert", "__name__", "q2")) / 2) keep_metric_names)`
r1 := netstorage.Result{ r1 := netstorage.Result{
MetricName: storage.MetricName{ MetricName: metricNameExpected,
MetricGroup: []byte("q1"),
},
Values: []float64{500, 600, 700, 800, 900, 1000}, Values: []float64{500, 600, 700, 800, 900, 1000},
Timestamps: timestampsExpected, Timestamps: timestampsExpected,
} }
r1.MetricName.MetricGroup = []byte("q1")
r1.MetricName.Tags = []storage.Tag{{ r1.MetricName.Tags = []storage.Tag{{
Key: []byte("foo"), Key: []byte("foo"),
Value: []byte("bar"), Value: []byte("bar"),
}} }}
r2 := netstorage.Result{ r2 := netstorage.Result{
MetricName: storage.MetricName{ MetricName: metricNameExpected,
MetricGroup: []byte("q2"),
},
Values: []float64{5, 5, 5, 5, 5, 5}, Values: []float64{5, 5, 5, 5, 5, 5},
Timestamps: timestampsExpected, Timestamps: timestampsExpected,
} }
r2.MetricName.MetricGroup = []byte("q2")
r2.MetricName.Tags = []storage.Tag{{ r2.MetricName.Tags = []storage.Tag{{
Key: []byte("foo"), Key: []byte("foo"),
Value: []byte("qwert"), Value: []byte("qwert"),
@ -3080,23 +3078,21 @@ func TestExecSuccess(t *testing.T) {
t.Parallel() t.Parallel()
q := `sort_desc(2 * (label_set(time(), "foo", "bar", "__name__", "q1"), label_set(10, "foo", "qwert", "__name__", "q2")) keep_metric_names)` q := `sort_desc(2 * (label_set(time(), "foo", "bar", "__name__", "q1"), label_set(10, "foo", "qwert", "__name__", "q2")) keep_metric_names)`
r1 := netstorage.Result{ r1 := netstorage.Result{
MetricName: storage.MetricName{ MetricName: metricNameExpected,
MetricGroup: []byte("q1"),
},
Values: []float64{2000, 2400, 2800, 3200, 3600, 4000}, Values: []float64{2000, 2400, 2800, 3200, 3600, 4000},
Timestamps: timestampsExpected, Timestamps: timestampsExpected,
} }
r1.MetricName.MetricGroup = []byte("q1")
r1.MetricName.Tags = []storage.Tag{{ r1.MetricName.Tags = []storage.Tag{{
Key: []byte("foo"), Key: []byte("foo"),
Value: []byte("bar"), Value: []byte("bar"),
}} }}
r2 := netstorage.Result{ r2 := netstorage.Result{
MetricName: storage.MetricName{ MetricName: metricNameExpected,
MetricGroup: []byte("q2"),
},
Values: []float64{20, 20, 20, 20, 20, 20}, Values: []float64{20, 20, 20, 20, 20, 20},
Timestamps: timestampsExpected, Timestamps: timestampsExpected,
} }
r2.MetricName.MetricGroup = []byte("q2")
r2.MetricName.Tags = []storage.Tag{{ r2.MetricName.Tags = []storage.Tag{{
Key: []byte("foo"), Key: []byte("foo"),
Value: []byte("qwert"), Value: []byte("qwert"),
@ -3132,23 +3128,21 @@ func TestExecSuccess(t *testing.T) {
t.Parallel() t.Parallel()
q := `sort_desc(2 * on() group_right() (label_set(time(), "foo", "bar", "__name__", "q1"), label_set(10, "foo", "qwert", "__name__", "q2")) keep_metric_names)` q := `sort_desc(2 * on() group_right() (label_set(time(), "foo", "bar", "__name__", "q1"), label_set(10, "foo", "qwert", "__name__", "q2")) keep_metric_names)`
r1 := netstorage.Result{ r1 := netstorage.Result{
MetricName: storage.MetricName{ MetricName: metricNameExpected,
MetricGroup: []byte("q1"),
},
Values: []float64{2000, 2400, 2800, 3200, 3600, 4000}, Values: []float64{2000, 2400, 2800, 3200, 3600, 4000},
Timestamps: timestampsExpected, Timestamps: timestampsExpected,
} }
r1.MetricName.MetricGroup = []byte("q1")
r1.MetricName.Tags = []storage.Tag{{ r1.MetricName.Tags = []storage.Tag{{
Key: []byte("foo"), Key: []byte("foo"),
Value: []byte("bar"), Value: []byte("bar"),
}} }}
r2 := netstorage.Result{ r2 := netstorage.Result{
MetricName: storage.MetricName{ MetricName: metricNameExpected,
MetricGroup: []byte("q2"),
},
Values: []float64{20, 20, 20, 20, 20, 20}, Values: []float64{20, 20, 20, 20, 20, 20},
Timestamps: timestampsExpected, Timestamps: timestampsExpected,
} }
r2.MetricName.MetricGroup = []byte("q2")
r2.MetricName.Tags = []storage.Tag{{ r2.MetricName.Tags = []storage.Tag{{
Key: []byte("foo"), Key: []byte("foo"),
Value: []byte("qwert"), Value: []byte("qwert"),