Method Select

pkg/querier/distributor_queryable.go:99–158

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

(ctx context.Context, sortSeries 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 *distributorQuerier) Select(ctx context.Context, sortSeries bool, sp *storage.SelectHints, matchers ...*labels.Matcher) storage.SeriesSet {
	log, ctx := spanlogger.New(ctx, "distributorQuerier.Select")
	defer log.Finish()

	minT, maxT := q.mint, q.maxt
	if sp != nil {
		minT, maxT = sp.Start, sp.End
	}

	// We should manipulate the query mint to query samples up until
	// now - queryIngestersWithin, because older time ranges are covered by the storage. This
	// optimization is particularly important for the blocks storage where the blocks retention in the
	// ingesters could be way higher than queryIngestersWithin.
	if q.queryIngestersWithin > 0 {
		now := time.Now()
		origMinT := minT
		minT = max(minT, util.TimeToMillis(now.Add(-q.queryIngestersWithin)))

		if origMinT != minT {
			level.Debug(log).Log("msg", "the min time of the query to ingesters has been manipulated", "original", origMinT, "updated", minT)
		}

		if minT > maxT {
			level.Debug(log).Log("msg", "empty query time range after min time manipulation")
			return storage.EmptySeriesSet()
		}
	}

	partialDataEnabled := q.partialDataEnabled(ctx)

	// In the recent versions of Prometheus, we pass in the hint but with Func set to "series".
	// See: https://github.com/prometheus/prometheus/pull/8050
	if sp != nil && sp.Func == "series" {
		var (
			ms  []labels.Labels
			err error
		)

		if q.streamingMetadata {
			ms, err = q.distributor.MetricsForLabelMatchersStream(ctx, model.Time(minT), model.Time(maxT), sp, partialDataEnabled, matchers...)
		} else {
			ms, err = q.distributor.MetricsForLabelMatchers(ctx, model.Time(minT), model.Time(maxT), sp, partialDataEnabled, matchers...)
		}

		if err != nil && !partialdata.IsPartialDataError(err) {
			return storage.ErrSeriesSet(err)
		}

		seriesSet := series.LabelsSetToSeriesSet(sortSeries, ms)

		if partialdata.IsPartialDataError(err) {
			warning := seriesSet.Warnings()
			return series.NewSeriesSetWithWarnings(seriesSet, warning.Add(err))
		}

		return seriesSet
	}