Skip to content

Commit 6da364e

Browse files
authored
chore: Set memberlist func for ingester-rf1 init (#13424)
1 parent 1fa5127 commit 6da364e

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

pkg/loki/loki.go

+3
Original file line numberDiff line numberDiff line change
@@ -257,6 +257,9 @@ func (c *Config) Validate() error {
257257
if err := c.Ingester.Validate(); err != nil {
258258
errs = append(errs, errors.Wrap(err, "CONFIG ERROR: invalid ingester config"))
259259
}
260+
if err := c.IngesterRF1.Validate(); err != nil {
261+
errs = append(errs, errors.Wrap(err, "CONFIG ERROR: invalid ingester config"))
262+
}
260263
if err := c.LimitsConfig.Validate(); err != nil {
261264
errs = append(errs, errors.Wrap(err, "CONFIG ERROR: invalid limits_config config"))
262265
}

pkg/loki/modules.go

+1
Original file line numberDiff line numberDiff line change
@@ -1406,6 +1406,7 @@ func (t *Loki) initMemberlistKV() (services.Service, error) {
14061406
t.Cfg.Ruler.Ring.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV
14071407
t.Cfg.BloomCompactor.Ring.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV
14081408
t.Cfg.Pattern.LifecyclerConfig.RingConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV
1409+
t.Cfg.IngesterRF1.LifecyclerConfig.RingConfig.KVStore.MemberlistKV = t.MemberlistKV.GetMemberlistKV
14091410
t.Server.HTTP.Handle("/memberlist", t.MemberlistKV)
14101411

14111412
if t.Cfg.InternalServer.Enable {

0 commit comments

Comments
 (0)