Skip to content

Commit

Permalink
chore: remove initialization of Ingester RF-1 (#14814)
Browse files Browse the repository at this point in the history
  • Loading branch information
grobinson-grafana authored Nov 7, 2024
1 parent ca06d21 commit ed5ea97
Showing 1 changed file with 0 additions and 11 deletions.
11 changes: 0 additions & 11 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 @@ -355,7 +354,6 @@ type Loki struct {
TenantLimits validation.TenantLimits
distributor *distributor.Distributor
Ingester ingester.Interface
IngesterRF1 ingester_rf1.Interface
PatternIngester *pattern.Ingester
PatternRingClient pattern.RingClient
Querier querier.Querier
Expand Down Expand Up @@ -639,15 +637,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 ed5ea97

Please sign in to comment.