(querierTestConfig *querier.TestConfig, reg prometheus.Registerer, logger log.Logger)
| 222 | } |
| 223 | |
| 224 | func testQueryableFunc(querierTestConfig *querier.TestConfig, reg prometheus.Registerer, logger log.Logger) storage.QueryableFunc { |
| 225 | if querierTestConfig != nil { |
| 226 | // disable active query tracking for test |
| 227 | querierTestConfig.Cfg.ActiveQueryTrackerDir = "" |
| 228 | |
| 229 | overrides := validation.NewOverrides(querier.DefaultLimitsConfig(), nil) |
| 230 | q, _, _ := querier.New(querierTestConfig.Cfg, overrides, querierTestConfig.Distributor, querierTestConfig.Stores, reg, logger, nil) |
| 231 | return func(mint, maxt int64) (storage.Querier, error) { |
| 232 | return q.Querier(mint, maxt) |
| 233 | } |
| 234 | } |
| 235 | |
| 236 | return func(mint, maxt int64) (storage.Querier, error) { |
| 237 | return storage.NoopQuerier(), nil |
| 238 | } |
| 239 | } |
| 240 | |
| 241 | func testSetup(t *testing.T, querierTestConfig *querier.TestConfig) (*promql.Engine, storage.QueryableFunc, Pusher, log.Logger, RulesLimits, prometheus.Registerer) { |
| 242 | tracker := promql.NewActiveQueryTracker(t.TempDir(), 20, promslog.NewNopLogger()) |
no test coverage detected