Function TestQueryRangeMaxSeries

integration/api/query_range_test.go:577–617

(t *testing.T)

}

func TestQueryRangeMaxSeries(t *testing.T) {
	util.RunIntegrationTests(t, util.TestHarnessConfig{
		ConfigOverlay: configQueryRangeMaxSeries,
	}, 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()

		tracesSent := 0
	sendLoop:
		for {
			select {
			case <-ticker.C:
				require.NoError(t, h.WriteJaegerBatch(util.MakeThriftBatch(), ""))
				tracesSent++
			case <-timer.C:
				break sendLoop
			}
		}

		require.Greater(t, tracesSent, 3)
		h.WaitTracesQueryable(t, tracesSent)

		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_PARTIAL, queryRangeRes.GetStatus())
			require.Equal(t, "Response exceeds maximum series limit of 3, a partial response is returned. Warning: the accuracy of each individual value is not guaranteed.", queryRangeRes.GetMessage())
			require.Equal(t, 3, len(queryRangeRes.GetSeries()))
		})
	})
}

func TestQueryRangeMaxSeriesDisabled(t *testing.T) {
	util.RunIntegrationTests(t, util.TestHarnessConfig{