Method createRulesManager

pkg/ruler/manager.go:257–272

(user string, ctx context.Context)

}

func (r *DefaultMultiTenantManager) createRulesManager(user string, ctx context.Context) RulesManager {
	r.userManagerMtx.Lock()
	defer r.userManagerMtx.Unlock()

	manager, err := r.newManager(ctx, user)
	if err != nil {
		r.lastReloadSuccessful.WithLabelValues(user).Set(0)
		level.Error(r.logger).Log("msg", "unable to create rule manager", "user", user, "err", err)
		return nil
	}
	// manager.Run() starts running the manager and blocks until Stop() is called.
	// Hence run it as another goroutine.
	go manager.Run()
	r.userManagers[user] = manager
	return manager
}

func defaultRuleGroupIterationFunc(ctx context.Context, g *promRules.Group, evalTimestamp time.Time) {
	logMessage := []any{