Method forLiveStoreRing

modules/querier/querier.go:316–334

forLiveStoreRing runs f, in parallel, for instances selected from the live-store ring.

(ctx context.Context, f forEachFn)

// forLiveStoreRing runs f, in parallel, for instances selected from the live-store ring.
func (q *Querier) forLiveStoreRing(ctx context.Context, f forEachFn) ([]any, error) {
	if ctx.Err() != nil {
		_ = level.Debug(log.Logger).Log("forLiveStoreRing context error", "ctx.Err()", ctx.Err().Error())
		return nil, ctx.Err()
	}

	ctx, span := tracer.Start(ctx, "Querier.forLiveStoreRing")
	defer span.End()

	if q.partitionRing == nil {
		return nil, errors.New("forLiveStoreRing: partition ring is not configured")
	}

	rs, err := q.partitionRing.GetReplicationSetsForOperation(ring.Read)
	if err != nil {
		return nil, fmt.Errorf("error finding partition ring replicas: %w", err)
	}
	return forPartitionRingReplicaSets(ctx, q, rs, f)
}

// forLiveStoreMetricsRing runs f, in parallel, for instances selected from the live-store ring.
func (q *Querier) forLiveStoreMetricsRing(ctx context.Context, f forEachMetricsFn) ([]any, error) {