loadbalancer

Documentation

Index

• Constants
• type LeastConnPolicy
  • func NewLeastConnLoadBalancer(targets []string, weights []int) *LeastConnPolicy
  • func (p *LeastConnPolicy) ChooseTarget(_ []string) string
  • func (p *LeastConnPolicy) Done(target string)
• type LoadBalancer
• type RandomPolicy
  • func NewRandomLoadBalancer() *RandomPolicy
  • func (p *RandomPolicy) ChooseTarget(targets []string) string
  • func (p *RandomPolicy) Done(_ string)
• type RoundRobinPolicy
  • func NewRoundRobinLoadBalancer() *RoundRobinPolicy
  • func (p *RoundRobinPolicy) ChooseTarget(targets []string) string
  • func (p *RoundRobinPolicy) Done(_ string)
• type WeightedRoundRobinPolicy
  • func NewWRoundRobinLoadBalancer(weights []int) *WeightedRoundRobinPolicy
  • func (p *WeightedRoundRobinPolicy) ChooseTarget(targets []string) string
  • func (p *WeightedRoundRobinPolicy) Done(_ string)

Constants

const (
	RoundRobin              string = "round_robin"
	WeightedRoundRobin      string = "weighted_round_robin"
	LeastConnection         string = "least_conn"
	WeightedLeastConnection string = "weighted_least_conn"
	Random                  string = "random"
)

Types

type LeastConnPolicy

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

func NewLeastConnLoadBalancer

func NewLeastConnLoadBalancer(targets []string, weights []int) *LeastConnPolicy

func (*LeastConnPolicy) ChooseTarget

func (p *LeastConnPolicy) ChooseTarget(_ []string) string

func (*LeastConnPolicy) Done

func (p *LeastConnPolicy) Done(target string)

type LoadBalancer

type LoadBalancer interface {
	ChooseTarget(targets []string) string
	Done(target string)
}

type RandomPolicy

type RandomPolicy struct{}

func NewRandomLoadBalancer

func NewRandomLoadBalancer() *RandomPolicy

func (*RandomPolicy) ChooseTarget

func (p *RandomPolicy) ChooseTarget(targets []string) string

func (*RandomPolicy) Done

func (p *RandomPolicy) Done(_ string)

type RoundRobinPolicy

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

func NewRoundRobinLoadBalancer

func NewRoundRobinLoadBalancer() *RoundRobinPolicy

func (*RoundRobinPolicy) ChooseTarget

func (p *RoundRobinPolicy) ChooseTarget(targets []string) string

func (*RoundRobinPolicy) Done

func (p *RoundRobinPolicy) Done(_ string)

type WeightedRoundRobinPolicy

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

func NewWRoundRobinLoadBalancer

func NewWRoundRobinLoadBalancer(weights []int) *WeightedRoundRobinPolicy

func (*WeightedRoundRobinPolicy) ChooseTarget

func (p *WeightedRoundRobinPolicy) ChooseTarget(targets []string) string

func (*WeightedRoundRobinPolicy) Done

func (p *WeightedRoundRobinPolicy) Done(_ string)