Method syncRulesToManager

pkg/ruler/manager.go:203–249

syncRulesToManager maps the rule files to disk, detects any changes and will create/update the users Prometheus Rules Manager.

(ctx context.Context, user string, groups rulespb.RuleGroupList)

// syncRulesToManager maps the rule files to disk, detects any changes and will create/update the
// users Prometheus Rules Manager.
func (r *DefaultMultiTenantManager) syncRulesToManager(ctx context.Context, user string, groups rulespb.RuleGroupList) {
	// Map the files to disk and return the file names to be passed to the users manager if they
	// have been updated
	rulesUpdated, files, err := r.mapper.MapRules(user, groups.Formatted())
	if err != nil {
		r.lastReloadSuccessful.WithLabelValues(user).Set(0)
		level.Error(r.logger).Log("msg", "unable to map rule files", "user", user, "err", err)
		return
	}
	externalLabels, externalLabelsUpdated := r.userExternalLabels.update(user)

	existing := true
	manager := r.getRulesManager(user, ctx)
	if manager == nil {
		existing = false
		manager = r.createRulesManager(user, ctx)
	}

	if manager == nil {
		return
	}

	if !existing || rulesUpdated || externalLabelsUpdated {
		level.Debug(r.logger).Log("msg", "updating rules", "user", user)
		r.configUpdatesTotal.WithLabelValues(user).Inc()
		if (rulesUpdated || externalLabelsUpdated) && existing {
			r.updateRuleCache(user, manager.RuleGroups())
		}
		err = manager.Update(r.cfg.EvaluationInterval, files, externalLabels, r.cfg.ExternalURL.String(), r.ruleGroupIterationFunc)
		r.deleteRuleCache(user)
		if err != nil {
			r.lastReloadSuccessful.WithLabelValues(user).Set(0)
			level.Error(r.logger).Log("msg", "unable to update rule manager", "user", user, "err", err)
			return
		}
		if externalLabelsUpdated {
			if err = r.notifierApplyExternalLabels(user, externalLabels); err != nil {
				r.lastReloadSuccessful.WithLabelValues(user).Set(0)
				level.Error(r.logger).Log("msg", "unable to update notifier", "user", user, "err", err)
				return
			}
		}

		r.lastReloadSuccessful.WithLabelValues(user).Set(1)
		r.lastReloadSuccessfulTimestamp.WithLabelValues(user).SetToCurrentTime()
	}
}

func (r *DefaultMultiTenantManager) getRulesManager(user string, ctx context.Context) RulesManager {
	r.userManagerMtx.RLock()