()
| 810 | } |
| 811 | |
| 812 | func (t *Cortex) initStoreGateway() (serv services.Service, err error) { |
| 813 | t.Cfg.StoreGateway.ShardingRing.ListenPort = t.Cfg.Server.GRPCListenPort |
| 814 | |
| 815 | t.StoreGateway, err = storegateway.NewStoreGateway(t.Cfg.StoreGateway, t.Cfg.BlocksStorage, t.OverridesConfig, t.Cfg.Server.LogLevel, util_log.Logger, prometheus.DefaultRegisterer, t.ResourceMonitor) |
| 816 | if err != nil { |
| 817 | return nil, err |
| 818 | } |
| 819 | |
| 820 | // Expose HTTP endpoints. |
| 821 | t.API.RegisterStoreGateway(t.StoreGateway) |
| 822 | |
| 823 | return t.StoreGateway, nil |
| 824 | } |
| 825 | |
| 826 | func (t *Cortex) initMemberlistKV() (services.Service, error) { |
| 827 | reg := prometheus.DefaultRegisterer |
nothing calls this directly
no test coverage detected