Method SyncRuleGroups

pkg/ruler/manager.go:148–181

(ctx context.Context, ruleGroups map[string]rulespb.RuleGroupList)

}

func (r *DefaultMultiTenantManager) SyncRuleGroups(ctx context.Context, ruleGroups map[string]rulespb.RuleGroupList) {
	// this is a safety lock to ensure this method is executed sequentially
	r.syncRuleMtx.Lock()
	defer r.syncRuleMtx.Unlock()

	for userID, ruleGroup := range ruleGroups {
		r.syncRulesToManager(ctx, userID, ruleGroup)
	}

	r.userManagerMtx.Lock()
	defer r.userManagerMtx.Unlock()

	// Check for deleted users and remove them
	for userID, mngr := range r.userManagers {
		if _, exists := ruleGroups[userID]; !exists {
			go mngr.Stop()
			delete(r.userManagers, userID)

			r.removeNotifier(userID)
			r.mapper.cleanupUser(userID)
			r.userExternalLabels.remove(userID)
			r.lastReloadSuccessful.DeleteLabelValues(userID)
			r.lastReloadSuccessfulTimestamp.DeleteLabelValues(userID)
			r.configUpdatesTotal.DeleteLabelValues(userID)
			r.userManagerMetrics.RemoveUserRegistry(userID)
			if r.ruleEvalMetrics != nil {
				r.ruleEvalMetrics.deletePerUserMetrics(userID)
			}
			level.Info(r.logger).Log("msg", "deleted rule manager and local rule files", "user", userID)
		}
	}

	r.managersTotal.Set(float64(len(r.userManagers)))
}

func (r *DefaultMultiTenantManager) updateRuleCache(user string, rules []*promRules.Group) {
	r.ruleCacheMtx.Lock()