Skip to content

Commit 16112e4

Browse files
committed
Rebase fix-up
1 parent fb52bbb commit 16112e4

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

pkg/distributor/distributor.go

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -619,8 +619,11 @@ func (d *Distributor) AllUserStats(ctx context.Context) ([]UserIDStats, error) {
619619
req := &client.UserStatsRequest{}
620620
ctx = user.InjectOrgID(ctx, "1") // fake: ingester insists on having an org ID
621621
// Not using d.forAllIngesters(), so we can fail after first error.
622-
ingesters := d.ring.GetAll()
623-
for _, ingester := range ingesters {
622+
replicationSet, err := d.ring.GetAll()
623+
if err != nil {
624+
return nil, err
625+
}
626+
for _, ingester := range replicationSet.Ingesters {
624627
client, err := d.ingesterPool.GetClientFor(ingester.Addr)
625628
if err != nil {
626629
return nil, err

0 commit comments

Comments
 (0)