Function TestCountOverTimeInstantNs

pkg/traceql/engine_metrics_test.go:960–1005

(t *testing.T)

}

func TestCountOverTimeInstantNs(t *testing.T) {
	// not rounded values to simulate real world data
	start := 1*time.Second - 9*time.Nanosecond
	end := 3*time.Second + 9*time.Nanosecond
	step := end - start // for instant queries step == end-start
	req := &tempopb.QueryRangeRequest{
		Start: uint64(start),
		End:   uint64(end),
		Step:  uint64(step),
		Query: "{ } | count_over_time()",
	}
	req.SetInstant(true)

	in := []Span{
		// outside of the range but within the range for ms. Should be ignored.
		newMockSpan(nil).WithStartTime(uint64(start - 20*time.Nanosecond)).WithDuration(1),
		newMockSpan(nil).WithStartTime(uint64(start - time.Nanosecond)).WithDuration(1),

		// within the range
		newMockSpan(nil).WithStartTime(uint64(start)).WithDuration(1),
		newMockSpan(nil).WithStartTime(uint64(start + time.Nanosecond)).WithDuration(1),

		// within the range
		newMockSpan(nil).WithStartTime(uint64(end - time.Nanosecond)).WithDuration(1),
		newMockSpan(nil).WithStartTime(uint64(end)).WithDuration(10),

		// outside of the range but within the range for ms. Should be ignored.
		newMockSpan(nil).WithStartTime(uint64(end + time.Nanosecond)).WithDuration(1),
		newMockSpan(nil).WithStartTime(uint64(end + 20*time.Nanosecond)).WithDuration(1),
	}

	out := []TimeSeries{
		{
			Labels: []Label{
				{Name: "__name__", Value: NewStaticString("count_over_time")},
			},
			Values:    []float64{4},
			Exemplars: make([]Exemplar, 0),
		},
	}

	result, seriesCount, err := runTraceQLMetric(req, in)
	require.NoError(t, err)
	require.Equal(t, len(result), seriesCount)
	requireEqualSeriesSets(t, out, result)
}

func TestAvgOverTimeInstantNs(t *testing.T) {
	// not rounded values to simulate real world data