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
• type Uint32Slice
  • func (s Uint32Slice) Len() int
  • func (s Uint32Slice) Less(i, j int) bool
  • func (s Uint32Slice) Swap(i, j int)

Constants

const (
	// ConsistentHash ...
	ConsistentHash = "consistenthash"
	// HashNodes ...
	HashNodes = "hash.nodes"
	// HashArguments ...
	HashArguments = "hash.arguments"
)

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

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

const (
	// LeastActive ...
	LeastActive = "leastactive"
)

Functions

func GetWeight

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

GetWeight ...

func NewConsistentHashLoadBalance

func NewConsistentHashLoadBalance() cluster.LoadBalance

NewConsistentHashLoadBalance ...

func NewLeastActiveLoadBalance

func NewLeastActiveLoadBalance() cluster.LoadBalance

NewLeastActiveLoadBalance ...

func NewRandomLoadBalance

func NewRandomLoadBalance() cluster.LoadBalance

NewRandomLoadBalance ...

func NewRoundRobinLoadBalance

func NewRoundRobinLoadBalance() cluster.LoadBalance

NewRoundRobinLoadBalance ...

Types

type ConsistentHashLoadBalance

type ConsistentHashLoadBalance struct {
}

ConsistentHashLoadBalance ...

func (*ConsistentHashLoadBalance) Select

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

Select ...

type ConsistentHashSelector

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

ConsistentHashSelector ...

func (*ConsistentHashSelector) Select

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

Select ...

type Uint32Slice

type Uint32Slice []uint32

Uint32Slice ...

func (Uint32Slice) Len

func (s Uint32Slice) Len() int

func (Uint32Slice) Less

func (s Uint32Slice) Less(i, j int) bool

func (Uint32Slice) Swap

func (s Uint32Slice) Swap(i, j int)