()
| 791 | } |
| 792 | |
| 793 | func (t *Cortex) initParquetConverter() (serv services.Service, err error) { |
| 794 | t.Cfg.ParquetConverter.Ring.ListenPort = t.Cfg.Server.GRPCListenPort |
| 795 | return parquetconverter.NewConverter(t.Cfg.ParquetConverter, t.Cfg.BlocksStorage, t.Cfg.Compactor.BlockRanges.ToMilliseconds(), util_log.Logger, prometheus.DefaultRegisterer, t.OverridesConfig) |
| 796 | } |
| 797 | |
| 798 | func (t *Cortex) initCompactor() (serv services.Service, err error) { |
| 799 | t.Cfg.Compactor.ShardingRing.ListenPort = t.Cfg.Server.GRPCListenPort |
nothing calls this directly
no test coverage detected