balancer

Documentation

Index

• Variables
• type Balancer
  • func NewBalancer(strategy string) Balancer
• type RoundRobin
  • func (r *RoundRobin) NextIndex(total int) int
  • func (r *RoundRobin) NextPeer(nodes interface{}) (error, interface{})

Variables

var (
	ErrInputNotSlice   = errors.New("Input value is not silice")
	ErrNoAvaliableNode = errors.New("No nodes avaliable")
)

Types

type Balancer

type Balancer interface {
	NextPeer(nodes interface{}) (error, interface{})
}

func NewBalancer

func NewBalancer(strategy string) Balancer

NewBalancer 根据策略标识返回新的负载均衡器

type RoundRobin

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

func (*RoundRobin) NextIndex

func (r *RoundRobin) NextIndex(total int) int

NextIndex 返回下一个节点下标

func (*RoundRobin) NextPeer

func (r *RoundRobin) NextPeer(nodes interface{}) (error, interface{})

NextPeer 返回轮盘的下一节点