(t *testing.T, rulerConfig Config, querierTestConfig *querier.TestConfig, store rulestore.RuleStore, rulerAddrMap map[string]*Ruler)
| 324 | } |
| 325 | |
| 326 | func buildRuler(t *testing.T, rulerConfig Config, querierTestConfig *querier.TestConfig, store rulestore.RuleStore, rulerAddrMap map[string]*Ruler) (*Ruler, *DefaultMultiTenantManager) { |
| 327 | engine, queryable, pusher, logger, overrides, reg := testSetup(t, querierTestConfig) |
| 328 | metrics := NewRuleEvalMetrics(rulerConfig, reg) |
| 329 | managerFactory := DefaultTenantManagerFactory(rulerConfig, pusher, queryable, engine, overrides, metrics, reg) |
| 330 | manager, err := NewDefaultMultiTenantManager(rulerConfig, &ruleLimits{}, managerFactory, metrics, reg, log.NewNopLogger()) |
| 331 | require.NoError(t, err) |
| 332 | |
| 333 | ruler, err := newRuler( |
| 334 | rulerConfig, |
| 335 | manager, |
| 336 | reg, |
| 337 | logger, |
| 338 | store, |
| 339 | overrides, |
| 340 | newMockClientsPool(rulerConfig, logger, reg, rulerAddrMap), |
| 341 | ) |
| 342 | require.NoError(t, err) |
| 343 | return ruler, manager |
| 344 | } |
| 345 | |
| 346 | func buildRulerWithIterFunc(t *testing.T, rulerConfig Config, querierTestConfig *querier.TestConfig, store rulestore.RuleStore, rulerAddrMap map[string]*Ruler, ruleGroupIterFunc promRules.GroupEvalIterationFunc) (*Ruler, *DefaultMultiTenantManager) { |
| 347 | engine, queryable, pusher, logger, overrides, reg := testSetup(t, querierTestConfig) |
no test coverage detected