Function mockDistibutorFor

pkg/querier/querier_test.go:1318–1331

mockDistibutorFor duplicates the chunks in the mockChunkStore into the mockDistributor so we can test everything is dedupe correctly.

(t *testing.T, cks []chunk.Chunk)

// mockDistibutorFor duplicates the chunks in the mockChunkStore into the mockDistributor
// so we can test everything is dedupe correctly.
func mockDistibutorFor(t *testing.T, cks []chunk.Chunk) *MockDistributor {
	//parallel testing causes data race
	chunks, err := chunkcompat.ToChunks(cks)
	require.NoError(t, err)

	tsc := client.TimeSeriesChunk{
		Labels: []cortexpb.LabelAdapter{{Name: model.MetricNameLabel, Value: "foo"}},
		Chunks: chunks,
	}

	result := &MockDistributor{}
	result.On("QueryStream", mock.Anything, mock.Anything, mock.Anything, mock.Anything).Return(&client.QueryStreamResponse{Chunkseries: []client.TimeSeriesChunk{tsc}}, nil)
	return result
}

func testRangeQuery(t testing.TB, queryable storage.Queryable, queryEngine promql.QueryEngine, end model.Time, q query, enc promchunk.Encoding) *promql.Result {
	from, through, step := time.Unix(0, 0), end.Time(), q.step