Function TestQueryRangeSingleTrace

integration/api/query_range_test.go:548–575

TestQueryRangeSingleTrace checks count for a single trace Single trace creates a block with startTime == endTime which covers a few edge cases under the hood.

(t *testing.T)

// Single trace creates a block with startTime == endTime
// which covers a few edge cases under the hood.
func TestQueryRangeSingleTrace(t *testing.T) {
	util.RunIntegrationTests(t, util.TestHarnessConfig{
		DeploymentMode: util.DeploymentModeSingleBinary, // for unknown reasons this fails on microservices mode. TODO: figure that crap out
	}, func(h *util.TempoHarness) {
		h.WaitTracesWritable(t)
		// Emit a single trace
		require.NoError(t, h.WriteJaegerBatch(util.MakeThriftBatch(), ""))

		h.WaitTracesQueryable(t, 1)

		// Query the trace by count. As we have only one trace, we should get one dot with value 1
		query := "{} | count_over_time()"
		callQueryRange(t, h, queryRangeRequest{Query: query, Exemplars: 100}, func(queryRangeRes *tempopb.QueryRangeResponse, err error) {
			require.NoError(t, err)
			require.NotNil(t, queryRangeRes)
			require.Equal(t, len(queryRangeRes.GetSeries()), 1)

			series := queryRangeRes.GetSeries()[0]
			assert.Equal(t, len(series.GetExemplars()), 1)

			var sum float64
			for _, sample := range series.GetSamples() {
				sum += sample.Value
			}
			require.InDelta(t, sum, 1, 0.000001)
		})
	})
}

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