Function TestNaiveQueryRangeCombine

integration/api/combine_test.go:178–320

(t *testing.T)

}

func TestNaiveQueryRangeCombine(t *testing.T) {
	tests := []struct {
		name     string
		rNew     *tempopb.QueryRangeResponse
		rInto    *tempopb.QueryRangeResponse
		expected *tempopb.QueryRangeResponse
	}{
		{
			name: "combine series with different labels",
			rNew: &tempopb.QueryRangeResponse{
				Series: []*tempopb.TimeSeries{
					{
						Labels: []v1.KeyValue{
							{Key: "foo", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "bar"}}},
						},
						Samples: []tempopb.Sample{{TimestampMs: 1000, Value: 1.0}},
					},
				},
				Metrics: &tempopb.SearchMetrics{
					InspectedBytes:  100,
					CompletedJobs:   1,
					InspectedTraces: 10,
					InspectedSpans:  50,
				},
			},
			rInto: &tempopb.QueryRangeResponse{
				Series: []*tempopb.TimeSeries{
					{
						Labels: []v1.KeyValue{
							{Key: "baz", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "qux"}}},
						},
						Samples: []tempopb.Sample{{TimestampMs: 2000, Value: 2.0}},
					},
				},
				Metrics: &tempopb.SearchMetrics{
					InspectedBytes:  50,
					CompletedJobs:   1,
					InspectedTraces: 5,
					InspectedSpans:  25,
				},
			},
			expected: &tempopb.QueryRangeResponse{
				Series: []*tempopb.TimeSeries{
					{
						Labels: []v1.KeyValue{
							{Key: "baz", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "qux"}}},
						},
						Samples: []tempopb.Sample{{TimestampMs: 2000, Value: 2.0}},
					},
					{
						Labels: []v1.KeyValue{
							{Key: "foo", Value: &v1.AnyValue{Value: &v1.AnyValue_StringValue{StringValue: "bar"}}},
						},
						Samples: []tempopb.Sample{{TimestampMs: 1000, Value: 1.0}},
					},
				},
				Metrics: &tempopb.SearchMetrics{
					InspectedBytes:  150,