Method Select

pkg/querier/querier_test.go:1467–1497

Select implements storage.Querier interface. The bool passed is ignored because the series is always sorted.

(_ context.Context, _ bool, sp *storage.SelectHints, matchers ...*labels.Matcher)

// Select implements storage.Querier interface.
// The bool passed is ignored because the series is always sorted.
func (q *mockStoreQuerier) Select(_ context.Context, _ bool, sp *storage.SelectHints, matchers ...*labels.Matcher) storage.SeriesSet {
	// If we don't skip here, it'll make /series lookups extremely slow as all the chunks will be loaded.
	// That flag is only to be set with blocks storage engine, and this is a protective measure.
	if sp != nil && sp.Func == "series" {
		return storage.EmptySeriesSet()
	}

	chunks, err := q.store.Get()
	if err != nil {
		return storage.ErrSeriesSet(err)
	}

	cs := make([]storage.Series, 0, len(chunks))
	chunksBySeries := map[string][]chunk.Chunk{}

	for _, c := range chunks {
		key := client.LabelsToKeyString(c.Metric)
		chunksBySeries[key] = append(chunksBySeries[key], c)
	}

	for i, c := range chunksBySeries {
		cs = append(cs, &storage.SeriesEntry{
			Lset: chunksBySeries[i][0].Metric,
			SampleIteratorFn: func(it chunkenc.Iterator) chunkenc.Iterator {
				return q.chunkIteratorFunc(it, c, model.Time(mint), model.Time(maxt))
			},
		})
	}

	return series.NewConcreteSeriesSet(true, cs)
}

func (q *mockStoreQuerier) LabelValues(ctx context.Context, name string, _ *storage.LabelHints, labels ...*labels.Matcher) ([]string, annotations.Annotations, error) {
	return nil, nil, nil