Method isUserOwned

pkg/ruler/ruler.go:775–807

(userID string)

}

func (r *Ruler) isUserOwned(userID string) (bool, error) {
	if !r.allowedTenants.IsAllowed(userID) {
		return false, nil
	}

	// If sharding is disabled, any ruler instance owns all users.
	if !r.cfg.EnableSharding {
		return true, nil
	}

	if r.cfg.ShardingStrategy == util.ShardingStrategyShuffle {
		shardSize := r.getShardSizeForUser(userID)
		subRing := r.ring.ShuffleShard(userID, shardSize)

		rs, err := subRing.GetAllHealthy(RingOp)
		if err != nil {
			r.ringCheckErrors.Inc()
			level.Error(r.logger).Log("msg", "failed to get rulers from ring", "user", userID, "err", err)
			return false, err
		}

		return rs.Includes(r.lifecycler.GetInstanceAddr()), nil
	}

	rulers, err := r.ring.Get(users.ShardByUser(userID), RingOp, nil, nil, nil)
	if err != nil {
		r.ringCheckErrors.Inc()
		level.Error(r.logger).Log("msg", "failed to get rulers from ring", "user", userID, "err", err)
		return false, err
	}

	return rulers.Includes(r.lifecycler.GetInstanceAddr()), nil
}

func (r *Ruler) syncRules(ctx context.Context, reason string) error {
	level.Info(r.logger).Log("msg", "syncing rules", "reason", reason)