()
| 151 | } |
| 152 | |
| 153 | func (t *Cortex) initRing() (serv services.Service, err error) { |
| 154 | t.Cfg.Ingester.LifecyclerConfig.RingConfig.KVStore.Multi.ConfigProvider = multiClientRuntimeConfigChannel(t.RuntimeConfig) |
| 155 | t.Ring, err = ring.New(t.Cfg.Ingester.LifecyclerConfig.RingConfig, "ingester", ingester.RingKey, util_log.Logger, prometheus.WrapRegistererWithPrefix("cortex_", prometheus.DefaultRegisterer)) |
| 156 | if err != nil { |
| 157 | return nil, err |
| 158 | } |
| 159 | |
| 160 | t.API.RegisterRing(t.Ring) |
| 161 | |
| 162 | return t.Ring, nil |
| 163 | } |
| 164 | |
| 165 | func (t *Cortex) initRuntimeConfig() (services.Service, error) { |
| 166 | if t.Cfg.RuntimeConfig.LoadPath == "" { |
nothing calls this directly
no test coverage detected