Method initRuler

pkg/cortex/modules.go:665–742

()

}

func (t *Cortex) initRuler() (serv services.Service, err error) {
	var manager *ruler.DefaultMultiTenantManager
	if t.RulerStorage == nil {
		level.Info(util_log.Logger).Log("msg", "RulerStorage is nil.  Not starting the ruler.")
		return nil, nil
	}

	t.Cfg.Ruler.LookbackDelta = t.Cfg.Querier.LookbackDelta
	t.Cfg.Ruler.FrontendTimeout = t.Cfg.Querier.Timeout
	t.Cfg.Ruler.PrometheusHTTPPrefix = t.Cfg.API.PrometheusHTTPPrefix
	t.Cfg.Ruler.Ring.ListenPort = t.Cfg.Server.GRPCListenPort
	t.Cfg.Ruler.NameValidationScheme = t.Cfg.NameValidationScheme
	metrics := ruler.NewRuleEvalMetrics(t.Cfg.Ruler, prometheus.DefaultRegisterer)

	rulerRegisterer := prometheus.WrapRegistererWith(prometheus.Labels{"engine": "ruler"}, prometheus.DefaultRegisterer)

	var (
		pusher      ruler.Pusher
		queryable   prom_storage.Queryable
		queryEngine promql.QueryEngine
	)
	if t.Cfg.ExternalPusher != nil {
		pusher = t.Cfg.ExternalPusher
	} else {
		pusher = t.Distributor
	}
	if t.Cfg.ExternalQueryable != nil {
		queryable = t.Cfg.ExternalQueryable

		opts := promql.EngineOpts{
			Logger:               util_log.SLogger,
			Reg:                  rulerRegisterer,
			ActiveQueryTracker:   createActiveQueryTracker(t.Cfg.Querier, util_log.SLogger),
			MaxSamples:           t.Cfg.Querier.MaxSamples,
			Timeout:              t.Cfg.Querier.Timeout,
			LookbackDelta:        t.Cfg.Querier.LookbackDelta,
			EnablePerStepStats:   t.Cfg.Querier.EnablePerStepStats,
			EnableAtModifier:     true,
			EnableNegativeOffset: true,
			NoStepSubqueryIntervalFn: func(int64) int64 {
				return t.Cfg.Querier.DefaultEvaluationInterval.Milliseconds()
			},
		}
		queryEngine = engine.New(opts, t.Cfg.Ruler.ThanosEngine, rulerRegisterer)
	} else {
		// TODO: Consider wrapping logger to differentiate from querier module logger
		queryable, _, queryEngine = querier.New(t.Cfg.Querier, t.OverridesConfig, t.Distributor, t.StoreQueryables, rulerRegisterer, util_log.Logger, t.OverridesConfig.RulesPartialData)
	}

	managerFactory := ruler.DefaultTenantManagerFactory(t.Cfg.Ruler, pusher, queryable, queryEngine, t.OverridesConfig, metrics, prometheus.DefaultRegisterer)
	manager, err = ruler.NewDefaultMultiTenantManager(t.Cfg.Ruler, t.OverridesConfig, managerFactory, metrics, prometheus.DefaultRegisterer, util_log.Logger)

	if err != nil {
		return nil, err
	}

	t.Ruler, err = ruler.NewRuler(
		t.Cfg.Ruler,