Method Apply

loadbalancer/algorithm.go:200–210

Apply implements routing.LBAlgorithm with a consistent hash algorithm.

(ctx *routing.LBContext)

// Apply implements routing.LBAlgorithm with a consistent hash algorithm.
func (ch *consistentHash) Apply(ctx *routing.LBContext) routing.LBEndpoint {
	if len(ctx.LBEndpoints) == 1 {
		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.Route.LBEndpoints[choice]
}

func (ch *consistentHash) chooseConsistentHashEndpoint(ctx *routing.LBContext) int {
	key, ok := ctx.Params[ConsistentHashKey].(string)