mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2026-07-23 17:21:27 +03:00
ed5dc35876
Disabling is done by making the the handlers for `/tags/tagSeries` and `/tags/tagMultiSeries` to return `501 (Not Implemented)` status code along with the error message saying that the API has been disabled and will be removed in future. See: https://github.com/VictoriaMetrics/VictoriaMetrics/issues/10544. Signed-off-by: Artem Fetishev <rtm@victoriametrics.com>
120 lines
3.0 KiB
Go
120 lines
3.0 KiB
Go
package tests
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/google/go-cmp/cmp"
|
|
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/apptest"
|
|
)
|
|
|
|
func testMetricsIndex(t *testing.T, sut apptest.PrometheusWriteQuerier) {
|
|
// verify index is empty at the start
|
|
expected := apptest.GraphiteMetricsIndexResponse{}
|
|
tenant := "1:2"
|
|
got := sut.GraphiteMetricsIndex(t, apptest.QueryOpts{Tenant: tenant})
|
|
if diff := cmp.Diff(expected, got); diff != "" {
|
|
t.Errorf("unexpected response (-want, +got):\n%s", diff)
|
|
}
|
|
|
|
// Mon Feb 5 09:57:36 CET 2024
|
|
const ingestTimestamp = ` 1707123456700`
|
|
dataSet := []string{
|
|
`metric_name_1{label="foo"} 10`,
|
|
`metric_name_1{label="bar"} 10`,
|
|
`metric_name_2{label="baz"} 20`,
|
|
`metric_name_1{label="baz"} 10`,
|
|
`metric_name_3{label="baz"} 30`,
|
|
}
|
|
|
|
for idx := range dataSet {
|
|
dataSet[idx] += ingestTimestamp
|
|
}
|
|
|
|
sut.PrometheusAPIV1ImportPrometheus(t, dataSet, apptest.QueryOpts{Tenant: tenant})
|
|
sut.ForceFlush(t)
|
|
|
|
// verify ingested metrics correctly returned in index response
|
|
expected = []string{"metric_name_1", "metric_name_2", "metric_name_3"}
|
|
|
|
got = sut.GraphiteMetricsIndex(t, apptest.QueryOpts{Tenant: tenant})
|
|
if diff := cmp.Diff(expected, got); diff != "" {
|
|
t.Errorf("unexpected response (-want, +got):\n%s", diff)
|
|
}
|
|
}
|
|
|
|
func TestSingleMetricsIndex(t *testing.T) {
|
|
tc := apptest.NewTestCase(t)
|
|
defer tc.Stop()
|
|
|
|
sut := tc.MustStartDefaultVmsingle()
|
|
|
|
testMetricsIndex(tc.T(), sut)
|
|
}
|
|
|
|
func TestClusterMetricsIndex(t *testing.T) {
|
|
tc := apptest.NewTestCase(t)
|
|
defer tc.Stop()
|
|
|
|
sut := tc.MustStartDefaultCluster()
|
|
|
|
testMetricsIndex(tc.T(), sut)
|
|
}
|
|
|
|
// testTagSeries tests the registration of new time series in index.
|
|
//
|
|
// See https://graphite.readthedocs.io/en/stable/tags.html#adding-series-to-the-tagdb.
|
|
func testTagSeries(tc *apptest.TestCase, sut apptest.PrometheusWriteQuerier, getStorageMetric func(string) int) {
|
|
t := tc.T()
|
|
|
|
assertNewTimeseriesCreatedTotal := func(want int) {
|
|
tc.Assert(&apptest.AssertOptions{
|
|
Msg: "unexpected vm_new_timeseries_created_total",
|
|
Got: func() any {
|
|
return getStorageMetric("vm_new_timeseries_created_total")
|
|
},
|
|
Want: want,
|
|
})
|
|
}
|
|
|
|
rec := "disk.used;rack=a1;datacenter=dc1;server=web01"
|
|
sut.GraphiteTagsTagSeries(t, rec, apptest.QueryOpts{})
|
|
assertNewTimeseriesCreatedTotal(0)
|
|
|
|
recs := []string{
|
|
"metric.yyy;t2=a;t1=b;t3=c",
|
|
"metric.zzz;t5=d;t4=e;t6=f",
|
|
"metric.xxx;t8=g;t7=h;t9=i",
|
|
}
|
|
sut.GraphiteTagsTagMultiSeries(t, recs, apptest.QueryOpts{})
|
|
assertNewTimeseriesCreatedTotal(0)
|
|
}
|
|
|
|
func TestSingleTagSeries(t *testing.T) {
|
|
tc := apptest.NewTestCase(t)
|
|
defer tc.Stop()
|
|
|
|
sut := tc.MustStartDefaultVmsingle()
|
|
getStorageMetric := func(name string) int {
|
|
return sut.GetIntMetric(t, name)
|
|
}
|
|
|
|
testTagSeries(tc, sut, getStorageMetric)
|
|
}
|
|
|
|
func TestClusterTagSeries(t *testing.T) {
|
|
tc := apptest.NewTestCase(t)
|
|
defer tc.Stop()
|
|
|
|
sut := tc.MustStartDefaultCluster()
|
|
getStorageMetric := func(name string) int {
|
|
var v int
|
|
for _, s := range sut.Vmstorages {
|
|
v += s.GetIntMetric(t, name)
|
|
}
|
|
return v
|
|
}
|
|
|
|
testTagSeries(tc, sut, getStorageMetric)
|
|
}
|