Function TestHistogramAggregator_EdgeCases

pkg/traceql/engine_metrics_test.go:3470–3553

(t *testing.T)

}

func TestHistogramAggregator_EdgeCases(t *testing.T) {
	// Use fixed timestamps to ensure deterministic behavior
	baseTime := time.Unix(1257894000, 0) // Fixed timestamp
	req := &tempopb.QueryRangeRequest{
		Start:     uint64(baseTime.UnixNano()),
		End:       uint64(baseTime.Add(1 * time.Hour).UnixNano()),
		Step:      uint64(15 * time.Second.Nanoseconds()),
		Exemplars: 5,
	}

	tests := []struct {
		name       string
		timeSeries []*tempopb.TimeSeries
		quantiles  []float64
		expectFunc func(t *testing.T, results SeriesSet)
	}{
		{
			name:      "no exemplars",
			quantiles: []float64{0.5, 0.9},
			timeSeries: []*tempopb.TimeSeries{
				{
					Labels: []commonv1proto.KeyValue{
						{Key: "service", Value: &commonv1proto.AnyValue{Value: &commonv1proto.AnyValue_StringValue{StringValue: "test"}}},
						{Key: internalLabelBucket, Value: &commonv1proto.AnyValue{Value: &commonv1proto.AnyValue_DoubleValue{DoubleValue: 2.0}}},
					},
					Samples: []tempopb.Sample{
						{TimestampMs: baseTime.UnixMilli(), Value: 5},
					},
					Exemplars: []tempopb.Exemplar{}, // No exemplars
				},
			},
			expectFunc: func(t *testing.T, results SeriesSet) {
				for _, series := range results {
					require.Empty(t, series.Exemplars, "Should have no exemplars")
				}
			},
		},
		{
			name:      "exemplars outside bucket ranges",
			quantiles: []float64{0.5},
			timeSeries: []*tempopb.TimeSeries{
				{
					Labels: []commonv1proto.KeyValue{
						{Key: "service", Value: &commonv1proto.AnyValue{Value: &commonv1proto.AnyValue_StringValue{StringValue: "test"}}},
						{Key: internalLabelBucket, Value: &commonv1proto.AnyValue{Value: &commonv1proto.AnyValue_DoubleValue{DoubleValue: 2.0}}},
					},
					Samples: []tempopb.Sample{
						{TimestampMs: baseTime.UnixMilli(), Value: 5},
					},
					Exemplars: []tempopb.Exemplar{
						{
							Value:       10.0, // Much larger than bucket, should not match
							TimestampMs: baseTime.UnixMilli(),
						},
					},
				},
			},
			expectFunc: func(t *testing.T, results SeriesSet) {