Method LabelNames

pkg/querier/distributor_queryable.go:265–296

(ctx context.Context, hints *storage.LabelHints, matchers ...*labels.Matcher)

}

func (q *distributorQuerier) LabelNames(ctx context.Context, hints *storage.LabelHints, matchers ...*labels.Matcher) ([]string, annotations.Annotations, error) {
	partialDataEnabled := q.partialDataEnabled(ctx)

	if len(matchers) > 0 && !q.labelNamesMatchers {
		return q.labelNamesWithMatchers(ctx, hints, partialDataEnabled, matchers...)
	}

	log, ctx := spanlogger.New(ctx, "distributorQuerier.LabelNames")
	defer log.Finish()

	var (
		ln  []string
		err error
	)

	if q.streamingMetadata {
		ln, err = q.labelsWithRetry(ctx, func() ([]string, error) {
			return q.distributor.LabelNamesStream(ctx, model.Time(q.mint), model.Time(q.maxt), hints, partialDataEnabled, matchers...)
		})
	} else {
		ln, err = q.labelsWithRetry(ctx, func() ([]string, error) {
			return q.distributor.LabelNames(ctx, model.Time(q.mint), model.Time(q.maxt), hints, partialDataEnabled, matchers...)
		})
	}

	if partialdata.IsPartialDataError(err) {
		warnings := annotations.Annotations(nil)
		return ln, warnings.Add(err), nil
	}

	return ln, nil, err
}

func (q *distributorQuerier) labelsWithRetry(ctx context.Context, labelsFunc func() ([]string, error)) ([]string, error) {
	if q.ingesterQueryMaxAttempts <= 1 {