(cfg Config, limits *validation.Overrides, reg prometheus.Registerer)
| 483 | } |
| 484 | |
| 485 | func initBlockStoreQueryable(cfg Config, limits *validation.Overrides, reg prometheus.Registerer) (*querier.BlocksStoreQueryable, error) { |
| 486 | // When running in single binary, if the blocks sharding is disabled and no custom |
| 487 | // store-gateway address has been configured, we can set it to the running process. |
| 488 | if cfg.isModuleEnabled(All) && !cfg.StoreGateway.ShardingEnabled && cfg.Querier.StoreGatewayAddresses == "" { |
| 489 | cfg.Querier.StoreGatewayAddresses = fmt.Sprintf("127.0.0.1:%d", cfg.Server.GRPCListenPort) |
| 490 | } |
| 491 | |
| 492 | return querier.NewBlocksStoreQueryableFromConfig(cfg.Querier, cfg.StoreGateway, cfg.BlocksStorage, limits, util_log.Logger, reg) |
| 493 | } |
| 494 | |
| 495 | func (t *Cortex) tsdbIngesterConfig() { |
| 496 | t.Cfg.Ingester.BlocksStorageConfig = t.Cfg.BlocksStorage |
no test coverage detected