Method MetricsMetadata

pkg/ingester/ingester.go:2266–2292

MetricsMetadata returns all the metric metadata of a user.

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

// MetricsMetadata returns all the metric metadata of a user.
func (i *Ingester) MetricsMetadata(ctx context.Context, req *client.MetricsMetadataRequest) (resp *client.MetricsMetadataResponse, err error) {
	i.stoppedMtx.RLock()
	if err := i.checkRunningOrStopping(); err != nil {
		i.stoppedMtx.RUnlock()
		return nil, err
	}
	i.stoppedMtx.RUnlock()

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

	// Set pprof labels for profiling
	pprof.Do(ctx, pprof.Labels("user", userID), func(ctx context.Context) {
		userMetadata := i.getUserMetadata(userID)

		if userMetadata == nil {
			resp = &client.MetricsMetadataResponse{}
			return
		}

		resp = &client.MetricsMetadataResponse{Metadata: userMetadata.toClientMetadata(req)}
	})

	return resp, nil
}

// CheckReady is the readiness handler used to indicate to k8s when the ingesters
// are ready for the addition or removal of another ingester.