()
| 497 | } |
| 498 | |
| 499 | func (t *Cortex) initIngesterService() (serv services.Service, err error) { |
| 500 | t.Cfg.Ingester.LifecyclerConfig.RingConfig.KVStore.Multi.ConfigProvider = multiClientRuntimeConfigChannel(t.RuntimeConfig) |
| 501 | t.Cfg.Ingester.LifecyclerConfig.ListenPort = t.Cfg.Server.GRPCListenPort |
| 502 | t.Cfg.Ingester.DistributorShardingStrategy = t.Cfg.Distributor.ShardingStrategy |
| 503 | t.Cfg.Ingester.DistributorShardByAllLabels = t.Cfg.Distributor.ShardByAllLabels |
| 504 | t.Cfg.Ingester.InstanceLimitsFn = ingesterInstanceLimits(t.RuntimeConfig) |
| 505 | t.Cfg.Ingester.QueryIngestersWithin = t.Cfg.Querier.QueryIngestersWithin |
| 506 | t.tsdbIngesterConfig() |
| 507 | |
| 508 | t.Ingester, err = ingester.New(t.Cfg.Ingester, t.OverridesConfig, prometheus.DefaultRegisterer, util_log.Logger, t.ResourceMonitor) |
| 509 | if err != nil { |
| 510 | return |
| 511 | } |
| 512 | |
| 513 | return t.Ingester, nil |
| 514 | } |
| 515 | |
| 516 | func (t *Cortex) initIngester() (serv services.Service, err error) { |
| 517 | t.API.RegisterIngester(t.Ingester, t.Cfg.Distributor, t.OverridesConfig) |
nothing calls this directly
no test coverage detected