From 6da364e94f79e1d494967fe08226a02ad2832268 Mon Sep 17 00:00:00 2001 From: benclive Date: Fri, 5 Jul 2024 15:49:51 +0100 Subject: [PATCH] chore: Set memberlist func for ingester-rf1 init (#13424) --- pkg/loki/loki.go | 3 +++ pkg/loki/modules.go | 1 + 2 files changed, 4 insertions(+) diff --git a/pkg/loki/loki.go b/pkg/loki/loki.go index ecc3c7dbc4da..91dde1b8ef14 100644 --- a/pkg/loki/loki.go +++ b/pkg/loki/loki.go @@ -257,6 +257,9 @@ func (c *Config) Validate() error { if err := c.Ingester.Validate(); err != nil { errs = append(errs, errors.Wrap(err, "CONFIG ERROR: invalid ingester config")) } + if err := c.IngesterRF1.Validate(); err != nil { + errs = append(errs, errors.Wrap(err, "CONFIG ERROR: invalid ingester config")) + } if err := c.LimitsConfig.Validate(); err != nil { errs = append(errs, errors.Wrap(err, "CONFIG ERROR: invalid limits_config config")) } diff --git a/pkg/loki/modules.go b/pkg/loki/modules.go index f7fb901e0cb9..9e6e033c5e61 100644 --- a/pkg/loki/modules.go +++ b/pkg/loki/modules.go @@ -1406,6 +1406,7 @@ func (t *Loki) initMemberlistKV() (services.Service, error) { t.Cfg.Ruler.Ring.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV t.Cfg.BloomCompactor.Ring.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV t.Cfg.Pattern.LifecyclerConfig.RingConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV + t.Cfg.IngesterRF1.LifecyclerConfig.RingConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV t.Server.HTTP.Handle("/memberlist", t.MemberlistKV) if t.Cfg.InternalServer.Enable {