Function TestSliceSamples

pkg/querier/tripperware/merge_test.go:372–448

(t *testing.T)

}

func TestSliceSamples(t *testing.T) {
	t.Parallel()
	for _, tc := range []struct {
		name            string
		samples         []cortexpb.Sample
		minTs           int64
		expectedSamples []cortexpb.Sample
	}{
		{
			name:            "empty samples",
			samples:         nil,
			expectedSamples: nil,
		},
		{
			name: "minTs smaller than first sample's timestamp",
			samples: []cortexpb.Sample{
				{Value: 0, TimestampMs: 1},
			},
			minTs: 0,
			expectedSamples: []cortexpb.Sample{
				{Value: 0, TimestampMs: 1},
			},
		},
		{
			name: "input samples are not sorted, return all samples",
			samples: []cortexpb.Sample{
				{Value: 0, TimestampMs: 3}, {Value: 0, TimestampMs: 1},
			},
			minTs: 2,
			expectedSamples: []cortexpb.Sample{
				{Value: 0, TimestampMs: 3}, {Value: 0, TimestampMs: 1},
			},
		},
		{
			name: "minTs greater than the last sample's timestamp",
			samples: []cortexpb.Sample{
				{Value: 0, TimestampMs: 1}, {Value: 0, TimestampMs: 2},
			},
			minTs:           3,
			expectedSamples: []cortexpb.Sample{},
		},
		{
			name: "input samples not sorted, minTs greater than the last sample's timestamp",
			samples: []cortexpb.Sample{
				{Value: 0, TimestampMs: 0}, {Value: 0, TimestampMs: 3}, {Value: 0, TimestampMs: 1},
			},
			minTs:           2,
			expectedSamples: []cortexpb.Sample{},
		},
		{
			name: "input samples are sorted",
			samples: []cortexpb.Sample{
				{Value: 0, TimestampMs: 2}, {Value: 0, TimestampMs: 3}, {Value: 0, TimestampMs: 4},
			},
			minTs: 1,
			expectedSamples: []cortexpb.Sample{
				{Value: 0, TimestampMs: 2}, {Value: 0, TimestampMs: 3}, {Value: 0, TimestampMs: 4},
			},