()
| 866 | } |
| 867 | |
| 868 | func (t *Cortex) initQueryScheduler() (services.Service, error) { |
| 869 | if t.Cfg.TenantFederation.Enabled && t.Cfg.TenantFederation.RegexMatcherEnabled { |
| 870 | // If regex matcher enabled, we use regex validator to pass regex to the querier |
| 871 | users.WithDefaultResolver(tenantfederation.NewRegexValidator()) |
| 872 | } |
| 873 | |
| 874 | s, err := scheduler.NewScheduler(t.Cfg.QueryScheduler, t.OverridesConfig, util_log.Logger, prometheus.DefaultRegisterer, t.Cfg.Querier.DistributedExecEnabled) |
| 875 | if err != nil { |
| 876 | return nil, errors.Wrap(err, "query-scheduler init") |
| 877 | } |
| 878 | |
| 879 | t.API.RegisterQueryScheduler(s) |
| 880 | return s, nil |
| 881 | } |
| 882 | |
| 883 | func (t *Cortex) initResourceMonitor() (services.Service, error) { |
| 884 | if t.Cfg.ResourceMonitor.Resources.String() == "" || len(t.Cfg.ResourceMonitor.Resources) == 0 { |
nothing calls this directly
no test coverage detected