Method labelsValuesCommon

pkg/ingester/ingester.go:1931–1988

labelsValuesCommon returns all label values that are associated with a given label name. this should be used by LabelValues and LabelValuesStream the cleanup function should be called in order to close the querier

(ctx context.Context, req *client.LabelValuesRequest)

// this should be used by LabelValues and LabelValuesStream
// the cleanup function should be called in order to close the querier
func (i *Ingester) labelsValuesCommon(ctx context.Context, req *client.LabelValuesRequest) (*client.LabelValuesResponse, func(), error) {
	cleanup := func() {}
	if err := i.checkRunning(); err != nil {
		return nil, cleanup, err
	}

	labelName, startTimestampMs, endTimestampMs, limit, matchers, err := client.FromLabelValuesRequest(i.matchersCache, req)
	if err != nil {
		return nil, cleanup, err
	}

	userID, err := users.TenantID(ctx)
	if err != nil {
		return nil, cleanup, err
	}

	db, err := i.getTSDB(userID)
	if err != nil || db == nil {
		return &client.LabelValuesResponse{}, cleanup, nil
	}

	if err := db.acquireReadLock(); err != nil {
		return &client.LabelValuesResponse{}, cleanup, nil
	}
	defer db.releaseReadLock()

	mint, maxt, err := metadataQueryRange(startTimestampMs, endTimestampMs, db, i.cfg.QueryIngestersWithin)
	if err != nil {
		return nil, cleanup, err
	}

	q, err := db.Querier(mint, maxt)
	if err != nil {
		return nil, cleanup, err
	}

	cleanup = func() {
		q.Close()
	}

	c, err := i.trackInflightQueryRequest()
	if err != nil {
		return nil, cleanup, err
	}
	defer c()
	vals, _, err := q.LabelValues(ctx, labelName, &storage.LabelHints{Limit: limit}, matchers...)
	if err != nil {
		return nil, cleanup, err
	}

	if limit > 0 && len(vals) > limit {
		vals = vals[:limit]
	}

	return &client.LabelValuesResponse{
		LabelValues: vals,
	}, cleanup, nil
}