e2e: basic utf8 tests

Signed-off-by: Michael Hoffmann <[email protected]>

Author: MichaHoffmann

test/e2e/query_test.go

@@ -2468,3 +2468,47 @@ func TestChainDeduplication(t *testing.T) {
 		},
 	)
 }
+
+func TestSidecarUTF8Labels(t *testing.T) {
+	t.Parallel()
+
+	e, err := e2e.NewDockerEnvironment("sidecar-utf8")
+	testutil.Ok(t, err)
+	t.Cleanup(e2ethanos.CleanScenario(t, e))
+
+	promCfg := e2ethanos.DefaultPromConfig("prom", 0, "", "", e2ethanos.LocalPrometheusTarget)
+	prom, sidecar := e2ethanos.NewPrometheusWithSidecar(e, "p1", promCfg, "", e2ethanos.DefaultPrometheusImage(), "")
+	testutil.Ok(t, e2e.StartAndWaitReady(prom, sidecar))
+
+	endpoints := []string{
+		sidecar.InternalEndpoint("grpc"),
+	}
+	querier := e2ethanos.
+		NewQuerierBuilder(e, "1", endpoints...).
+		Init()
+	testutil.Ok(t, e2e.StartAndWaitReady(querier))
+
+	now := time.Now()
+	ctx := context.Background()
+	m := model.Sample{
+		Metric: map[model.LabelName]model.LabelValue{
+			"__name__": "🔥",
+		},
+		Value:     model.SampleValue(2),
+		Timestamp: model.TimeFromUnixNano(now.Add(time.Minute).UnixNano()),
+	}
+	testutil.Ok(t, synthesizeSamples(ctx, prom, []model.Sample{m}))
+
+	retv := instantQuery(t, context.Background(), querier.Endpoint("http"), func() string {
+		return `{"🔥"}`
+	}, func() time.Time { return now.Add(time.Minute) }, promclient.QueryOptions{Deduplicate: true}, 1)
+
+	testutil.Equals(t, model.Vector{&model.Sample{
+		Metric: model.Metric{
+			"__name__":   "🔥",
+			"prometheus": "prom",
+		},
+		Value:     model.SampleValue(2),
+		Timestamp: model.TimeFromUnixNano(now.Add(time.Minute).UnixNano()),
+	}}, retv)
+}

test/e2e/store_gateway_test.go

@@ -620,6 +620,41 @@ func TestStoreGatewayNoCacheFile(t *testing.T) {
 		)
 		testutil.Ok(t, s1.WaitSumMetrics(e2emon.Equals(7+2), "thanos_bucket_store_series_blocks_queried"))
 	})
+	t.Run("upload block id6 with utf8 labels", func(t *testing.T) {
+		series := []labels.Labels{labels.FromStrings("a", "1", "🚀", "🔥")}
+		extLset := labels.FromStrings("ext1", "value1", "replica", "1")
+		id6, err := e2eutil.CreateBlockWithBlockDelay(ctx, dir, series, 10, timestamp.FromTime(now), timestamp.FromTime(now.Add(2*time.Hour)), 30*time.Minute, extLset, 0, metadata.NoneFunc, nil)
+		testutil.Ok(t, err)
+		testutil.Ok(t, objstore.UploadDir(ctx, l, bkt, path.Join(dir, id6.String()), id6.String()))
+
+		// Wait for store to sync blocks.
+		// thanos_blocks_meta_synced: 2x loadedMeta 1x labelExcludedMeta 1x TooFreshMeta 1x noMeta.
+		testutil.Ok(t, s1.WaitSumMetrics(e2emon.Equals(5), "thanos_blocks_meta_synced"))
+		testutil.Ok(t, s1.WaitSumMetrics(e2emon.Equals(0), "thanos_blocks_meta_sync_failures_total"))
+
+		testutil.Ok(t, s1.WaitSumMetrics(e2emon.Equals(2), "thanos_bucket_store_blocks_loaded"))
+		testutil.Ok(t, s1.WaitSumMetrics(e2emon.Equals(2), "thanos_bucket_store_block_drops_total"))
+		testutil.Ok(t, s1.WaitSumMetrics(e2emon.Equals(0), "thanos_bucket_store_block_load_failures_total"))
+
+		queryAndAssertSeries(t, ctx, q.Endpoint("http"), func() string { return testQuery },
+			time.Now, promclient.QueryOptions{
+				Deduplicate: true,
+			},
+			[]model.Metric{
+				{
+					"a":    "1",
+					"b":    "2",
+					"ext1": "value1",
+				},
+				{
+					"a":    "1",
+					"🚀":    "🔥",
+					"ext1": "value1",
+				},
+			},
+		)
+		testutil.Ok(t, s1.WaitSumMetrics(e2emon.Equals(9+2), "thanos_bucket_store_series_blocks_queried"))
+	})
 }
 
 func TestStoreGatewayMemcachedCache(t *testing.T) {