Function TestAvgOverTimeInstantNs

pkg/traceql/engine_metrics_test.go:1007–1052

(t *testing.T)

}

func TestAvgOverTimeInstantNs(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: "{ } | avg_over_time(span:duration)",
	}
	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(uint64(1 * time.Second)),
		newMockSpan(nil).WithStartTime(uint64(start - time.Nanosecond)).WithDuration(uint64(2 * time.Second)),

		// within the range
		newMockSpan(nil).WithStartTime(uint64(start)).WithDuration(uint64(3 * time.Second)),
		newMockSpan(nil).WithStartTime(uint64(start + time.Nanosecond)).WithDuration(uint64(4 * time.Second)),

		// within the range
		newMockSpan(nil).WithStartTime(uint64(end - time.Nanosecond)).WithDuration(uint64(5 * time.Second)),
		newMockSpan(nil).WithStartTime(uint64(end)).WithDuration(uint64(6 * time.Second)),

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

	out := []TimeSeries{
		{
			Labels: []Label{
				{Name: "__name__", Value: NewStaticString("avg_over_time")},
			},
			Values:    []float64{(3 + 4 + 5 + 6) / 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)
}

// TestCountOverTimeInstantNsWithCutoff simulates merge behavior in L2 and L3.
func TestCountOverTimeInstantNsWithCutoff(t *testing.T) {