Function TestSanitizeLabels

storage/diskmetricstore_test.go:1182–1260

(t *testing.T)

}

func TestSanitizeLabels(t *testing.T) {
	dms := NewDiskMetricStore("", 100*time.Millisecond, nil, logger)

	// Push mf1c with the grouping matching mf1b, mf1b should end up in storage.
	ts1 := time.Now()
	grouping1 := map[string]string{
		"job":      "job1",
		"instance": "instance2",
	}
	errCh := make(chan error, 1)
	dms.SubmitWriteRequest(WriteRequest{
		Labels:         grouping1,
		Timestamp:      ts1,
		MetricFamilies: testutil.MetricFamiliesMap(mf1c),
		Done:           errCh,
	})
	for err := range errCh {
		t.Fatal("Unexpected error:", err)
	}
	pushTimestamp := newPushTimestampGauge(grouping1, ts1)
	pushFailedTimestamp := newPushFailedTimestampGauge(grouping1, time.Time{})
	if err := checkMetricFamilies(
		dms, mf1b,
		pushTimestamp, pushFailedTimestamp,
	); err != nil {
		t.Error(err)
	}

	// Push mf1e, missing the instance label. Again, mf1b should end up in storage.
	ts2 := ts1.Add(1)
	errCh = make(chan error, 1)
	dms.SubmitWriteRequest(WriteRequest{
		Labels:         grouping1,
		Timestamp:      ts2,
		MetricFamilies: testutil.MetricFamiliesMap(mf1e),
		Done:           errCh,
	})
	for err := range errCh {
		t.Fatal("Unexpected error:", err)
	}
	pushTimestamp = newPushTimestampGauge(grouping1, ts2)
	if err := checkMetricFamilies(
		dms, mf1b,
		pushTimestamp, pushFailedTimestamp,
	); err != nil {
		t.Error(err)
	}

	// Push mf1e, missing the instance label, into a grouping without the
	// instance label. The result in the storage should have an empty
	// instance label.
	ts3 := ts2.Add(1)
	grouping3 := map[string]string{
		"job": "job1",
	}
	errCh = make(chan error, 1)
	dms.SubmitWriteRequest(WriteRequest{
		Labels:         grouping3,