From f90d1ee399e756bec80885c9fe823c77bc024ac8 Mon Sep 17 00:00:00 2001 From: JordanRushing Date: Wed, 8 Jun 2022 16:46:33 -0500 Subject: [PATCH] Backport Memberlist status page in k101 (#6342) Signed-off-by: JordanRushing --- pkg/loki/loki.go | 1 + pkg/loki/modules.go | 2 ++ 2 files changed, 3 insertions(+) diff --git a/pkg/loki/loki.go b/pkg/loki/loki.go index 1ff6e9ec494f8..42a042e1f12cf 100644 --- a/pkg/loki/loki.go +++ b/pkg/loki/loki.go @@ -513,6 +513,7 @@ func (t *Loki) setupModuleManager() error { All: {QueryScheduler, QueryFrontend, Querier, Ingester, Distributor, Ruler, Compactor}, Read: {QueryScheduler, QueryFrontend, Querier, Ruler, Compactor}, Write: {Ingester, Distributor}, + MemberlistKV: {Server}, } // Add IngesterQuerier as a dependency for store when target is either querier, ruler, or read. diff --git a/pkg/loki/modules.go b/pkg/loki/modules.go index e71b47b948a77..5c8444075e190 100644 --- a/pkg/loki/modules.go +++ b/pkg/loki/modules.go @@ -837,6 +837,8 @@ func (t *Loki) initMemberlistKV() (services.Service, error) { t.Cfg.QueryScheduler.SchedulerRing.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV t.Cfg.Ruler.Ring.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV + t.Server.HTTP.Handle("/memberlist", t.MemberlistKV) + return t.MemberlistKV, nil }