Skip to content

Commit 055e6ee

Browse files
committed
Add a utf8 query test case
Signed-off-by: SungJin1212 <[email protected]>
1 parent 6998d49 commit 055e6ee

File tree

1 file changed

+15
-3
lines changed

1 file changed

+15
-3
lines changed

integration/utf8_test.go

Lines changed: 15 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import (
99
"testing"
1010
"time"
1111

12+
"github.com/prometheus/common/model"
1213
"github.com/prometheus/prometheus/prompb"
1314
"github.com/stretchr/testify/require"
1415

@@ -105,16 +106,16 @@ overrides:
105106
require.NoError(t, s.StartAndWaitReady(cortex))
106107

107108
// user-1 uses legacy validation
108-
user1Client, err := e2ecortex.NewClient(cortex.HTTPEndpoint(), "", "", "", "user-1")
109+
user1Client, err := e2ecortex.NewClient(cortex.HTTPEndpoint(), cortex.HTTPEndpoint(), "", "", "user-1")
109110
require.NoError(t, err)
110111

111112
// user-2 uses utf8 validation
112-
user2Client, err := e2ecortex.NewClient(cortex.HTTPEndpoint(), "", "", "", "user-2")
113+
user2Client, err := e2ecortex.NewClient(cortex.HTTPEndpoint(), cortex.HTTPEndpoint(), "", "", "user-2")
113114
require.NoError(t, err)
114115

115116
now := time.Now()
116117

117-
utf8Series, _ := generateSeries("series_1", now, prompb.Label{Name: "test.utf8.metric", Value: "😄"})
118+
utf8Series, _ := generateSeries("series.1", now, prompb.Label{Name: "test.utf8.metric", Value: "😄"})
118119
legacySeries, _ := generateSeries("series_2", now, prompb.Label{Name: "job", Value: "test"})
119120

120121
res, err := user1Client.Push(legacySeries)
@@ -134,4 +135,15 @@ overrides:
134135
res, err = user2Client.Push(utf8Series)
135136
require.NoError(t, err)
136137
require.Equal(t, 200, res.StatusCode)
138+
139+
// utf8 querying
140+
// c.f. https://prometheus.io/docs/guides/utf8/#querying
141+
query := `{"series.1", "test.utf8.metric"="😄"}`
142+
queryResult, err := user2Client.Query(query, now)
143+
require.NoError(t, err)
144+
require.Equal(t, 200, res.StatusCode)
145+
require.Equal(t, model.ValVector, queryResult.Type())
146+
vec := queryResult.(model.Vector)
147+
require.Equal(t, 1, len(vec))
148+
137149
}

0 commit comments

Comments
 (0)