Function TestIngesterMetadata

integration/ingester_metadata_test.go:19–77

(t *testing.T)

)

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

	// Start dependencies.
	consul := e2edb.NewConsul()
	require.NoError(t, s.StartAndWaitReady(consul))

	baseFlags := mergeFlags(AlertmanagerLocalFlags(), BlocksStorageFlags())

	minio := e2edb.NewMinio(9000, baseFlags["-blocks-storage.s3.bucket-name"])
	require.NoError(t, s.StartAndWaitReady(minio))

	flags := mergeFlags(baseFlags, map[string]string{
		// alert manager
		"-alertmanager.web.external-url": "http://localhost/alertmanager",
		// consul
		"-ring.store":      "consul",
		"-consul.hostname": consul.NetworkHTTPEndpoint(),
	})

	// Start Cortex components
	distributor := e2ecortex.NewDistributor("distributor", e2ecortex.RingStoreConsul, consul.NetworkHTTPEndpoint(), flags, "")
	ingester := e2ecortex.NewIngester("ingester", e2ecortex.RingStoreConsul, consul.NetworkHTTPEndpoint(), flags, "")
	querier := e2ecortex.NewQuerier("querier", e2ecortex.RingStoreConsul, consul.NetworkHTTPEndpoint(), flags, "")
	require.NoError(t, s.StartAndWaitReady(distributor, ingester, querier))

	// Wait until distributor has updated the ring.
	require.NoError(t, distributor.WaitSumMetricsWithOptions(e2e.Equals(1), []string{"cortex_ring_members"}, e2e.WithLabelMatchers(
		labels.MustNewMatcher(labels.MatchEqual, "name", "ingester"),
		labels.MustNewMatcher(labels.MatchEqual, "state", "ACTIVE"))))

	// Wait until querier has updated the ring.
	require.NoError(t, querier.WaitSumMetricsWithOptions(e2e.Equals(1), []string{"cortex_ring_members"}, e2e.WithLabelMatchers(
		labels.MustNewMatcher(labels.MatchEqual, "name", "ingester"),
		labels.MustNewMatcher(labels.MatchEqual, "state", "ACTIVE"))))

	client, err := e2ecortex.NewClient(distributor.HTTPEndpoint(), querier.HTTPEndpoint(), "", "", userID)
	require.NoError(t, err)

	metadataMetricNum := 5
	metadataPerMetrics := 2
	metadata := make([]prompb.MetricMetadata, 0, metadataMetricNum)
	for i := 0; i < metadataMetricNum; i++ {
		for j := 0; j < metadataPerMetrics; j++ {
			metadata = append(metadata, prompb.MetricMetadata{
				MetricFamilyName: fmt.Sprintf("metadata_name_%d", i),
				Help:             fmt.Sprintf("metadata_help_%d_%d", i, j),
				Unit:             fmt.Sprintf("metadata_unit_%d_%d", i, j),
			})
		}
	}
	res, err := client.Push(nil, metadata...)
	require.NoError(t, err)
	require.Equal(t, 200, res.StatusCode)

	testMetadataQueryParams(t, client, metadataMetricNum, metadataPerMetrics)