Skip to content

Commit 7339ddb

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

File tree

1 file changed

+14
-3
lines changed

1 file changed

+14
-3
lines changed

integration/utf8_test.go

Lines changed: 14 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,14 @@ overrides:
134135
res, err = user2Client.Push(utf8Series)
135136
require.NoError(t, err)
136137
require.Equal(t, 200, res.StatusCode)
138+
139+
// utf8 querying
140+
query := `{"series.1", "test.utf8.metric"="😄"}`
141+
queryResult, err := user2Client.Query(query, now)
142+
require.NoError(t, err)
143+
require.Equal(t, 200, res.StatusCode)
144+
require.Equal(t, model.ValVector, queryResult.Type())
145+
vec := queryResult.(model.Vector)
146+
require.Equal(t, 1, len(vec))
147+
137148
}

0 commit comments

Comments
 (0)