Function TestIngester_Push_OutOfOrderLabels

pkg/ingester/ingester_test.go:2646–2680

(t *testing.T)

}

func TestIngester_Push_OutOfOrderLabels(t *testing.T) {
	// Create ingester
	cfg := defaultIngesterTestConfig(t)
	r := prometheus.NewRegistry()
	i, err := prepareIngesterWithBlocksStorage(t, cfg, r)
	require.NoError(t, err)
	require.NoError(t, services.StartAndAwaitRunning(context.Background(), i))
	defer services.StopAndAwaitTerminated(context.Background(), i) //nolint:errcheck

	// Wait until it's ACTIVE
	test.Poll(t, time.Second, ring.ACTIVE, func() any {
		return i.lifecycler.GetState()
	})

	ctx := user.InjectOrgID(context.Background(), "test-user")

	outOfOrderLabels := []cortexpb.LabelAdapter{
		{Name: labels.MetricName, Value: "test_metric"},
		{Name: "c", Value: "3"},
		{Name: "a", Value: "1"},
	}

	req, _ := mockWriteRequest(t, cortexpb.FromLabelAdaptersToLabels(outOfOrderLabels), 1, 2)
	_, err = i.Push(ctx, req)
	require.Error(t, err)
	require.Contains(t, err.Error(), "out-of-order label set found")

	metric := `
		# HELP cortex_ingester_out_of_order_labels_total The total number of out of order label found per user.
		# TYPE cortex_ingester_out_of_order_labels_total counter
		cortex_ingester_out_of_order_labels_total{user="test-user"} 1
`
	err = testutil.GatherAndCompare(r, bytes.NewBufferString(metric), "cortex_ingester_out_of_order_labels_total")
	require.NoError(t, err)
}

func BenchmarkIngesterPush(b *testing.B) {
	limits := defaultLimitsTestConfig()