Method chooseConsistentHashEndpoint

loadbalancer/algorithm.go:212–226

(ctx *routing.LBContext)

}

func (ch *consistentHash) chooseConsistentHashEndpoint(ctx *routing.LBContext) int {
	key, ok := ctx.Params[ConsistentHashKey].(string)
	if !ok {
		key = snet.RemoteHost(ctx.Request).String()
	}
	balanceFactor, ok := ctx.Params[ConsistentHashBalanceFactor].(float64)
	var choice int
	if !ok {
		choice = ch.search(key, ctx)
	} else {
		choice = ch.boundedLoadSearch(key, balanceFactor, ctx)
	}

	return choice
}

type powerOfRandomNChoices struct {
	mu              sync.Mutex