Function TestQueryRangeExemplars

integration/api/query_range_test.go:56–515

(t *testing.T)

}

func TestQueryRangeExemplars(t *testing.T) {
	util.RunIntegrationTests(t, util.TestHarnessConfig{
		ConfigOverlay: configQueryRangeExemplars,
	}, func(h *util.TempoHarness) {
		h.WaitTracesWritable(t)

		ticker := time.NewTicker(500 * time.Millisecond)
		defer ticker.Stop()
		timer := time.NewTimer(10 * time.Second)
		defer timer.Stop()

		tracesSent := 0

		// send one batch every 500ms for 10 seconds
	sendLoop:
		for {
			select {
			case <-ticker.C:
				require.NoError(t, h.WriteJaegerBatch(
					util.MakeThriftBatchWithSpanCountAttributeAndName(
						1, "my operation",
						"res_val", "span_val",
						"res_attr", "span_attr",
					), ""),
				)
				require.NoError(t, h.WriteJaegerBatch(
					util.MakeThriftBatchWithSpanCountAttributeAndName(
						1, "my operation",
						"res_val2", "span_val2",
						"res_attr", "span_attr",
					), ""),
				)
				require.NoError(t, h.WriteJaegerBatch(
					util.MakeThriftBatchWithSpanCountAttributeAndName(
						1, "operation with high cardinality",
						uuid.New().String(), uuid.New().String(),
						"res_high_cardinality", "span_high_cardinality",
					), ""),
				)
				tracesSent += 3
			case <-timer.C:
				break sendLoop
			}
		}

		h.WaitTracesQueryable(t, tracesSent)

		for _, exemplarsCase := range []struct {
			name              string
			exemplars         int
			expectedExemplars int
		}{
			{
				name:              "default",
				exemplars:         0,
				expectedExemplars: 100, // if set to 0, then limits to 100
			},
			{