()
| 824 | } |
| 825 | |
| 826 | func (t *Cortex) initMemberlistKV() (services.Service, error) { |
| 827 | reg := prometheus.DefaultRegisterer |
| 828 | t.Cfg.MemberlistKV.MetricsRegisterer = reg |
| 829 | t.Cfg.MemberlistKV.Codecs = []codec.Codec{ |
| 830 | ring.GetCodec(), |
| 831 | ha.GetReplicaDescCodec(), |
| 832 | } |
| 833 | dnsProviderReg := prometheus.WrapRegistererWithPrefix( |
| 834 | "cortex_", |
| 835 | prometheus.WrapRegistererWith( |
| 836 | prometheus.Labels{"name": "memberlist"}, |
| 837 | reg, |
| 838 | ), |
| 839 | ) |
| 840 | dnsProvider := dns.NewProvider(util_log.Logger, dnsProviderReg, dns.GolangResolverType) |
| 841 | t.MemberlistKV = memberlist.NewKVInitService(&t.Cfg.MemberlistKV, util_log.Logger, dnsProvider, reg) |
| 842 | t.API.RegisterMemberlistKV(t.MemberlistKV) |
| 843 | |
| 844 | // Update the config. |
| 845 | t.Cfg.Distributor.DistributorRing.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV |
| 846 | t.Cfg.Distributor.HATrackerConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV |
| 847 | t.Cfg.Ingester.LifecyclerConfig.RingConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV |
| 848 | t.Cfg.StoreGateway.ShardingRing.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV |
| 849 | t.Cfg.Compactor.ShardingRing.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV |
| 850 | t.Cfg.Ruler.Ring.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV |
| 851 | t.Cfg.Alertmanager.ShardingRing.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV |
| 852 | t.Cfg.ParquetConverter.Ring.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV |
| 853 | |
| 854 | return t.MemberlistKV, nil |
| 855 | } |
| 856 | |
| 857 | func (t *Cortex) initTenantDeletionAPI() (services.Service, error) { |
| 858 | // t.RulerStorage can be nil when running in single-binary mode, and rule storage is not configured. |
nothing calls this directly
no test coverage detected