(t *testing.T, ruleGroups []ruleGroupKey)
| 2620 | } |
| 2621 | |
| 2622 | func setupRuleGroupsStore(t *testing.T, ruleGroups []ruleGroupKey) (*objstore.InMemBucket, rulestore.RuleStore) { |
| 2623 | bucketClient := objstore.NewInMemBucket() |
| 2624 | usersScannerConfig := users.UsersScannerConfig{Strategy: users.UserScanStrategyList} |
| 2625 | reg := prometheus.NewPedanticRegistry() |
| 2626 | rs, err := bucketclient.NewBucketRuleStore(bucketClient, usersScannerConfig, nil, log.NewNopLogger(), reg) |
| 2627 | require.NoError(t, err) |
| 2628 | |
| 2629 | // "upload" rule groups |
| 2630 | for _, key := range ruleGroups { |
| 2631 | desc := rulespb.ToProto(key.user, key.namespace, rulefmt.RuleGroup{Name: key.group}) |
| 2632 | require.NoError(t, rs.SetRuleGroup(context.Background(), key.user, key.namespace, desc)) |
| 2633 | } |
| 2634 | |
| 2635 | return bucketClient, rs |
| 2636 | } |
| 2637 | |
| 2638 | type ruleGroupKey struct { |
| 2639 | user, namespace, group string |
no test coverage detected