balancers

Documentation

Index

• Variables
• type Balancer
• type Breaker
  • func BalancerWrapperBreaker(balancer Balancer) *Breaker
  • func (b *Breaker) Delete(key uint)
  • func (b *Breaker) Pop() (uint, error)
  • func (b *Breaker) Reduce(key uint)
  • func (b *Breaker) Success(key uint)
• type Lottery
  • func NewLottery(items map[uint]int) *Lottery
  • func (w *Lottery) Delete(key uint)
  • func (w *Lottery) Pop() (uint, error)
  • func (w *Lottery) Reduce(key uint)
  • func (w *Lottery) Success(key uint)
• type Node
  • func (n *Node) Reset(state State)
• type Rotor
  • func NewRotor(items map[uint]int) *Rotor
  • func (w *Rotor) Delete(key uint)
  • func (w *Rotor) Pop() (uint, error)
  • func (w *Rotor) Reduce(key uint)
  • func (w *Rotor) Success(key uint)
• type State

Variables

var (
	MaxFailures = 5                // 最多失败次数
	SleepWindow = 60 * time.Second // 冷却时间
	MaxRequests = 2                // 在 HalfOpen 状态下, 如果请求成功次数超过此数值，熔断器关闭（恢复）；如果有一个失败，重新进入 Open 状态
)

Types

type Balancer

type Balancer interface {
	Pop() (uint, error)
	Delete(key uint)
	Reduce(key uint)
	Success(key uint)
}

type Breaker

type Breaker struct {
	Balancer
}

func BalancerWrapperBreaker

func BalancerWrapperBreaker(balancer Balancer) *Breaker

func (*Breaker) Delete

func (b *Breaker) Delete(key uint)

func (*Breaker) Pop

func (b *Breaker) Pop() (uint, error)

func (*Breaker) Reduce

func (b *Breaker) Reduce(key uint)

func (*Breaker) Success

func (b *Breaker) Success(key uint)

type Lottery

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

按权重概率抽取，类似抽签。

func NewLottery

func NewLottery(items map[uint]int) *Lottery

func (*Lottery) Delete

func (w *Lottery) Delete(key uint)

func (*Lottery) Pop

func (w *Lottery) Pop() (uint, error)

func (*Lottery) Reduce

func (w *Lottery) Reduce(key uint)

func (*Lottery) Success

func (w *Lottery) Success(key uint)

type Node

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

func (*Node) Reset

func (n *Node) Reset(state State)

type Rotor

type Rotor struct {
	*list.List
	// contains filtered or unexported fields
}

按顺序循环轮转，每次降低权重后移到队尾

func NewRotor

func NewRotor(items map[uint]int) *Rotor

func (*Rotor) Delete

func (w *Rotor) Delete(key uint)

func (*Rotor) Pop

func (w *Rotor) Pop() (uint, error)

func (*Rotor) Reduce

func (w *Rotor) Reduce(key uint)

func (*Rotor) Success

func (w *Rotor) Success(key uint)

type State

type State int

const (
	StateClosed   State = iota // 正常运行
	StateOpen                  // 熔断触发
	StateHalfOpen              // 探测恢复
)