mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-12-23 08:56:31 +01:00
44 lines
992 B
Go
44 lines
992 B
Go
package prometheus
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vmselect/netstorage"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/lib/storage"
|
|
)
|
|
|
|
func TestFederate(t *testing.T) {
|
|
f := func(rs *netstorage.Result, expectedResult string) {
|
|
t.Helper()
|
|
result := Federate(rs)
|
|
if result != expectedResult {
|
|
t.Fatalf("unexpected result; got\n%s\nwant\n%s", result, expectedResult)
|
|
}
|
|
}
|
|
|
|
f(&netstorage.Result{}, ``)
|
|
|
|
f(&netstorage.Result{
|
|
MetricName: storage.MetricName{
|
|
MetricGroup: []byte("foo"),
|
|
Tags: []storage.Tag{
|
|
{
|
|
Key: []byte("a"),
|
|
Value: []byte("b"),
|
|
},
|
|
{
|
|
Key: []byte("qqq"),
|
|
Value: []byte("\\"),
|
|
},
|
|
{
|
|
Key: []byte("abc"),
|
|
// Verify that < isn't encoded. See https://github.com/VictoriaMetrics/VictoriaMetrics/issues/5431
|
|
Value: []byte("a<b\"\\c"),
|
|
},
|
|
},
|
|
},
|
|
Values: []float64{1.23},
|
|
Timestamps: []int64{123},
|
|
}, `foo{a="b",qqq="\\",abc="a<b\"\\c"} 1.23 123`+"\n")
|
|
}
|