(t *testing.T, rulerConfig Config, querierTestConfig *querier.TestConfig, store rulestore.RuleStore, rulerAddrMap map[string]*Ruler, ruleGroupIterFunc promRules.GroupEvalIterationFunc)
| 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) |
| 348 | metrics := NewRuleEvalMetrics(rulerConfig, reg) |
| 349 | managerFactory := DefaultTenantManagerFactory(rulerConfig, pusher, queryable, engine, overrides, metrics, reg) |
| 350 | manager, err := NewDefaultMultiTenantManagerWithIterationFunc(ruleGroupIterFunc, rulerConfig, &ruleLimits{}, managerFactory, metrics, reg, log.NewNopLogger()) |
| 351 | require.NoError(t, err) |
| 352 | |
| 353 | ruler, err := newRuler( |
| 354 | rulerConfig, |
| 355 | manager, |
| 356 | reg, |
| 357 | logger, |
| 358 | store, |
| 359 | overrides, |
| 360 | newMockClientsPool(rulerConfig, logger, reg, rulerAddrMap), |
| 361 | ) |
| 362 | require.NoError(t, err) |
| 363 | return ruler, manager |
| 364 | } |
| 365 | |
| 366 | func newTestRuler(t *testing.T, rulerConfig Config, store rulestore.RuleStore, querierTestConfig *querier.TestConfig) *Ruler { |
| 367 | ruler, _ := buildRuler(t, rulerConfig, querierTestConfig, store, nil) |
no test coverage detected