Function TestQueryRangeMaxSeriesDisabled

integration/api/query_range_test.go:619–657

(t *testing.T)

}

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

		ticker := time.NewTicker(500 * time.Millisecond)
		defer ticker.Stop()
		timer := time.NewTimer(5 * time.Second)
		defer timer.Stop()
		spanCount := 0
	sendLoop:
		for {
			select {
			case <-ticker.C:
				require.NoError(t, h.WriteJaegerBatch(util.MakeThriftBatch(), ""))
				spanCount++
			case <-timer.C:
				break sendLoop
			}
		}

		// Wait for traces to be flushed to blocks. spanCount happens to make traces count
		h.WaitTracesQueryable(t, spanCount)

		callQueryRange(t, h, queryRangeRequest{
			Query:     "{} | rate() by (span:id)",
			Start:     time.Now().Add(-5 * time.Minute),
			End:       time.Now(),
			Step:      "5s",
			Exemplars: 100,
		}, func(queryRangeRes *tempopb.QueryRangeResponse, err error) {
			require.NoError(t, err)
			require.NotNil(t, queryRangeRes)
			require.Equal(t, tempopb.PartialStatus_COMPLETE, queryRangeRes.GetStatus())
			require.Equal(t, spanCount, len(queryRangeRes.GetSeries()))
		})
	})
}

func TestQueryRangeTypeHandling(t *testing.T) {
	util.RunIntegrationTests(t, util.TestHarnessConfig{}, func(h *util.TempoHarness) {