Method userIndexUpdateLoop

pkg/ruler/ruler.go:743–773

(ctx context.Context)

}

func (r *Ruler) userIndexUpdateLoop(ctx context.Context) {
	// Hardcode ID to check which ruler owns updating user index.
	userID := users.UserIndexCompressedFilename
	// Align with clean up interval.
	ticker := time.NewTicker(util.DurationWithJitter(r.store.GetUserIndexUpdater().GetUpdateInterval(), 0.1))
	defer ticker.Stop()

	for {
		select {
		case <-ctx.Done():
			level.Error(r.logger).Log("msg", "context timeout, exit user index update loop", "err", ctx.Err())
			return
		case <-ticker.C:
			owned, err := r.isUserOwned(userID)
			if err != nil {
				level.Error(r.logger).Log("msg", "failed to check if ruler owns updating user index", "err", err)
				continue
			}
			if !owned {
				continue
			}
			start := time.Now()
			if err := r.userIndexUpdater.UpdateUserIndex(ctx); err != nil {
				level.Error(r.logger).Log("msg", "failed to update user index", "err", err)
				// Wait for next interval. Worst case, the user index scanner will fallback to list strategy.
				continue
			}
			level.Info(r.logger).Log("msg", "successfully updated user index", "duration_ms", time.Since(start).Milliseconds())
		}
	}
}

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