Function Test_PushQuery_UTF8

integration/utf8_test.go:174–264

(t *testing.T)

}

func Test_PushQuery_UTF8(t *testing.T) {
	s, err := e2e.NewScenario(networkName)
	require.NoError(t, err)
	defer s.Close()

	// Start dependencies.
	minio := e2edb.NewMinio(9000, bucketName)
	require.NoError(t, s.StartAndWaitReady(minio))

	// Start Cortex components.
	require.NoError(t, copyFileToSharedDir(s, "docs/configuration/single-process-config-blocks.yaml", cortexConfigFile))

	flags := map[string]string{
		"-auth.enabled":           "true",
		"-name-validation-scheme": "utf8",
		// ingester
		"-blocks-storage.s3.access-key-id":     e2edb.MinioAccessKey,
		"-blocks-storage.s3.secret-access-key": e2edb.MinioSecretKey,
		"-blocks-storage.s3.bucket-name":       bucketName,
		"-blocks-storage.s3.endpoint":          fmt.Sprintf("%s-minio-9000:9000", networkName),
		"-blocks-storage.s3.insecure":          "true",
		// alert manager
		"-alertmanager.web.external-url":   "http://localhost/alertmanager",
		"-alertmanager-storage.backend":    "local",
		"-alertmanager-storage.local.path": filepath.Join(e2e.ContainerSharedDir, "alertmanager_configs"),
	}
	// make alert manager config dir
	require.NoError(t, writeFileToSharedDir(s, "alertmanager_configs", []byte{}))

	cortex := e2ecortex.NewSingleBinaryWithConfigFile("cortex-1", cortexConfigFile, flags, "", 9009, 9095)
	require.NoError(t, s.StartAndWaitReady(cortex))

	c, err := e2ecortex.NewClient(cortex.HTTPEndpoint(), cortex.HTTPEndpoint(), "", "", "user-1")
	require.NoError(t, err)

	now := time.Now()

	utf8Series, _ := generateSeries("series.1", now, prompb.Label{Name: "test.utf8.metric", Value: "😄"})
	legacySeries, _ := generateSeries("series_2", now, prompb.Label{Name: "job", Value: "test"})

	metadata := []prompb.MetricMetadata{
		{
			MetricFamilyName: "metadata.name",
			Help:             "metadata.help",
			Unit:             "metadata.unit",
		},
	}

	res, err := c.Push(legacySeries, metadata...)
	require.NoError(t, err)
	require.Equal(t, 200, res.StatusCode)

	// utf8Series push should be success
	res, err = c.Push(utf8Series)
	require.NoError(t, err)
	require.Equal(t, 200, res.StatusCode)

	// utf8 querying