(cfg Config, logger log.Logger)
| 360 | } |
| 361 | |
| 362 | func multiTenantMiddleware(cfg Config, logger log.Logger) pipeline.AsyncMiddleware[combiner.PipelineResponse] { |
| 363 | if cfg.MultiTenantQueriesEnabled { |
| 364 | return pipeline.NewMultiTenantMiddleware(logger) |
| 365 | } |
| 366 | |
| 367 | return pipeline.NewNoopMiddleware() |
| 368 | } |
| 369 | |
| 370 | // blockMetasForSearch returns a list of blocks that are relevant to the search query. |
| 371 | // start and end are unix timestamps in seconds. rf is the replication factor of the blocks to return. |
no test coverage detected