loadbalance

Documentation

Index

• Constants
• func GetWeight(invoker protocol.Invoker, invocation protocol.Invocation) int64
• func NewConsistentHashLoadBalance() cluster.LoadBalance
• func NewLeastActiveLoadBalance() cluster.LoadBalance
• func NewRandomLoadBalance() cluster.LoadBalance
• func NewRoundRobinLoadBalance() cluster.LoadBalance
• type ConsistentHashLoadBalance
  • func (lb *ConsistentHashLoadBalance) Select(invokers []protocol.Invoker, invocation protocol.Invocation) protocol.Invoker
• type ConsistentHashSelector
  • func (c *ConsistentHashSelector) Select(invocation protocol.Invocation) protocol.Invoker

Constants

const (
	// ConsistentHash ...
	ConsistentHash = "consistenthash"
	// HashNodes ...
	HashNodes = "hash.nodes"
	// HashArguments  key of hash arguments  in url
	HashArguments = "hash.arguments"
)

const (
	// RoundRobin ...
	RoundRobin = "roundrobin"

	// COMPLETE ...
	COMPLETE = 0
	// UPDATING ...
	UPDATING = 1
)

const (
	// LeastActive is used to set the load balance extension
	LeastActive = "leastactive"
)

Functions

func GetWeight

func GetWeight(invoker protocol.Invoker, invocation protocol.Invocation) int64

GetWeight gets weight for load balance strategy

func NewConsistentHashLoadBalance

func NewConsistentHashLoadBalance() cluster.LoadBalance

NewConsistentHashLoadBalance creates NewConsistentHashLoadBalance

The same parameters of the request is always sent to the same provider.

func NewLeastActiveLoadBalance

func NewLeastActiveLoadBalance() cluster.LoadBalance

NewLeastActiveLoadBalance returns a least active load balance.

A random mechanism based on actives, actives means the number of a consumer's requests have been sent to provider but not yet got response.

func NewRandomLoadBalance

func NewRandomLoadBalance() cluster.LoadBalance

NewRandomLoadBalance returns a random load balance instance.

Set random probabilities by weight, and the request will be sent to provider randomly.

func NewRoundRobinLoadBalance

func NewRoundRobinLoadBalance() cluster.LoadBalance

NewRoundRobinLoadBalance returns a round robin load balance

Use the weight's common advisory to determine round robin ratio

Types

type ConsistentHashLoadBalance

type ConsistentHashLoadBalance struct {
}

ConsistentHashLoadBalance implementation of load balancing: using consistent hashing

func (*ConsistentHashLoadBalance) Select

func (lb *ConsistentHashLoadBalance) Select(invokers []protocol.Invoker, invocation protocol.Invocation) protocol.Invoker

Select gets invoker based on load balancing strategy

type ConsistentHashSelector

type ConsistentHashSelector struct {
	// contains filtered or unexported fields
}

ConsistentHashSelector implementation of Selector:get invoker based on load balancing strategy

func (*ConsistentHashSelector) Select

func (c *ConsistentHashSelector) Select(invocation protocol.Invocation) protocol.Invoker

Select gets invoker based on load balancing strategy