lb

Documentation

Index

• type Interface
  • func New(alg LoadBalanceAlgorithm) (Interface, error)
• type LoadBalanceAlgorithm
  • func (l *LoadBalanceAlgorithm) UnmarshalText(text []byte) error
• type RandomAlgorithm
  • func (r *RandomAlgorithm) Add(item Weighting)
  • func (r *RandomAlgorithm) Next(ctx context.Context) Weighting
• type RandomWeightAlgorithm
  • func (r *RandomWeightAlgorithm) Add(item Weighting)
  • func (r *RandomWeightAlgorithm) Next(ctx context.Context) Weighting
• type RoundRobinAlgorithm
  • func (r *RoundRobinAlgorithm) Add(item Weighting)
  • func (r *RoundRobinAlgorithm) Next(ctx context.Context) Weighting
• type Weighting

Types

type Interface

type Interface interface {
	Add(Weighting)
	Next(ctx context.Context) Weighting
}

func New

func New(alg LoadBalanceAlgorithm) (Interface, error)

type LoadBalanceAlgorithm

type LoadBalanceAlgorithm int32

const (
	Random LoadBalanceAlgorithm = iota
	RoundRobin
	RandomWeight
)

func (*LoadBalanceAlgorithm) UnmarshalText

func (l *LoadBalanceAlgorithm) UnmarshalText(text []byte) error

type RandomAlgorithm

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

func (*RandomAlgorithm) Add

func (r *RandomAlgorithm) Add(item Weighting)

func (*RandomAlgorithm) Next

func (r *RandomAlgorithm) Next(ctx context.Context) Weighting

type RandomWeightAlgorithm

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

func (*RandomWeightAlgorithm) Add

func (r *RandomWeightAlgorithm) Add(item Weighting)

func (*RandomWeightAlgorithm) Next

func (r *RandomWeightAlgorithm) Next(ctx context.Context) Weighting

type RoundRobinAlgorithm

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

func (*RoundRobinAlgorithm) Add

func (r *RoundRobinAlgorithm) Add(item Weighting)

func (*RoundRobinAlgorithm) Next

func (r *RoundRobinAlgorithm) Next(ctx context.Context) Weighting

type Weighting

type Weighting interface {
	Counting() bool
	Weight(ctx context.Context) int
}