Function seriesSetFromResponseStream

pkg/ingester/ingester_test.go:107–127

(s *mockQueryStreamServer)

}

func seriesSetFromResponseStream(s *mockQueryStreamServer) (storage.SeriesSet, error) {
	serieses := make([]storage.Series, 0, len(s.series))

	for _, result := range s.series {
		ls := cortexpb.FromLabelAdaptersToLabels(result.Labels)

		chunks, err := chunkcompat.FromChunks(ls, result.Chunks)
		if err != nil {
			return nil, err
		}

		serieses = append(serieses, &storage.SeriesEntry{
			Lset: ls,
			SampleIteratorFn: func(it chunkenc.Iterator) chunkenc.Iterator {
				return batch.NewChunkMergeIterator(it, chunks, math.MinInt64, math.MaxInt64)
			},
		})
	}
	set := series.NewConcreteSeriesSet(false, serieses)
	return set, nil
}

func TestMatcherCache(t *testing.T) {
	limits := defaultLimitsTestConfig()