()
| 796 | } |
| 797 | |
| 798 | func (t *Cortex) initCompactor() (serv services.Service, err error) { |
| 799 | t.Cfg.Compactor.ShardingRing.ListenPort = t.Cfg.Server.GRPCListenPort |
| 800 | ingestionReplicationFactor := t.Cfg.Ingester.LifecyclerConfig.RingConfig.ReplicationFactor |
| 801 | |
| 802 | t.Compactor, err = compactor.NewCompactor(t.Cfg.Compactor, t.Cfg.BlocksStorage, util_log.Logger, prometheus.DefaultRegisterer, t.OverridesConfig, ingestionReplicationFactor) |
| 803 | if err != nil { |
| 804 | return |
| 805 | } |
| 806 | |
| 807 | // Expose HTTP endpoints. |
| 808 | t.API.RegisterCompactor(t.Compactor) |
| 809 | return t.Compactor, nil |
| 810 | } |
| 811 | |
| 812 | func (t *Cortex) initStoreGateway() (serv services.Service, err error) { |
| 813 | t.Cfg.StoreGateway.ShardingRing.ListenPort = t.Cfg.Server.GRPCListenPort |
nothing calls this directly
no test coverage detected