Skip to content

Commit

Permalink
Remove initialization of Ingester RF-1
Browse files Browse the repository at this point in the history
  • Loading branch information
grobinson-grafana committed Nov 7, 2024
1 parent c02068e commit 2a1fe3f
Showing 1 changed file with 0 additions and 12 deletions.
12 changes: 0 additions & 12 deletions pkg/loki/loki.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,6 @@ import (
"github.com/grafana/loki/v3/pkg/distributor"
"github.com/grafana/loki/v3/pkg/indexgateway"
"github.com/grafana/loki/v3/pkg/ingester"
ingester_rf1 "github.com/grafana/loki/v3/pkg/ingester-rf1"
"github.com/grafana/loki/v3/pkg/ingester-rf1/metastore"
metastoreclient "github.com/grafana/loki/v3/pkg/ingester-rf1/metastore/client"
ingester_client "github.com/grafana/loki/v3/pkg/ingester/client"
Expand Down Expand Up @@ -356,8 +355,6 @@ type Loki struct {
TenantLimits validation.TenantLimits
distributor *distributor.Distributor
Ingester ingester.Interface
IngesterRF1 ingester_rf1.Interface
IngesterRF1RingClient *ingester_rf1.RingClient
PatternIngester *pattern.Ingester
PatternRingClient pattern.RingClient
Querier querier.Querier
Expand Down Expand Up @@ -641,15 +638,6 @@ func (t *Loki) readyHandler(sm *services.Manager, shutdownRequested *atomic.Bool
}
}

// Ingester RF1 has a special check that makes sure that it was able to register into the ring,
// and that all other ring entries are OK too.
if t.IngesterRF1 != nil {
if err := t.IngesterRF1.CheckReady(r.Context()); err != nil {
http.Error(w, "RF-1 Ingester not ready: "+err.Error(), http.StatusServiceUnavailable)
return
}
}

// Query Frontend has a special check that makes sure that a querier is attached before it signals
// itself as ready
if t.frontend != nil {
Expand Down

0 comments on commit 2a1fe3f

Please sign in to comment.