Struct DefaultMultiTenantManager

pkg/ruler/manager.go:33–71

)

type DefaultMultiTenantManager struct {
	cfg             Config
	notifierCfg     *config.Config
	managerFactory  ManagerFactory
	ruleEvalMetrics *RuleEvalMetrics
	frontendPool    *client.Pool

	mapper *mapper

	// Structs for holding per-user Prometheus rules Managers
	// and a corresponding metrics struct
	userManagerMtx     sync.RWMutex
	userManagers       map[string]RulesManager
	userManagerMetrics *ManagerMetrics

	// Per-user notifiers with separate queues.
	notifiersMtx              sync.Mutex
	notifiers                 map[string]*rulerNotifier
	notifiersDiscoveryMetrics map[string]discovery.DiscovererMetrics

	// Per-user externalLabels.
	userExternalLabels *userExternalLabels

	// rules backup
	rulesBackupManager *rulesBackupManager

	managersTotal                 prometheus.Gauge
	lastReloadSuccessful          *prometheus.GaugeVec
	lastReloadSuccessfulTimestamp *prometheus.GaugeVec
	configUpdatesTotal            *prometheus.CounterVec
	registry                      prometheus.Registerer
	logger                        log.Logger

	ruleCache    map[string][]*promRules.Group
	ruleCacheMtx sync.RWMutex
	syncRuleMtx  sync.Mutex

	ruleGroupIterationFunc promRules.GroupEvalIterationFunc
}

func NewDefaultMultiTenantManager(cfg Config, limits RulesLimits, managerFactory ManagerFactory, evalMetrics *RuleEvalMetrics, reg prometheus.Registerer, logger log.Logger) (*DefaultMultiTenantManager, error) {
	ncfg, err := buildNotifierConfig(&cfg)