Fix (*consistentHash).Apply

Signed-off-by: Roman Zavodskikh <[email protected]>
zalando · Mar 14, 2024 · 85ca505 · 85ca505
1 parent e8697c6
commit 85ca505
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/loadbalancer/algorithm.go b/loadbalancer/algorithm.go
@@ -199,8 +199,11 @@ func (ch *consistentHash) Apply(ctx *routing.LBContext) routing.LBEndpoint {
 		return ctx.LBEndpoints[0]
 	}
 
+	// The index returned from this call is taken from hash ring which is built from data about
+	// all endpoints, including fading in, unhealthy, etc. ones. The index stored in hash ring is
+	// the index of the endpoint in the original list of endpoints.
 	choice := ch.chooseConsistentHashEndpoint(ctx)
-	return ctx.LBEndpoints[choice]
+	return ctx.Route.LBEndpoints[choice]
 }
 
 func (ch *consistentHash) chooseConsistentHashEndpoint(ctx *routing.LBContext) int {