balance

Documentation

Index

• type Balancer
  • func New(opts ...BalancerOption) (*Balancer, error)
  • func (b *Balancer) GetMembers() []*server.Member
  • func (b *Balancer) Pick() (*server.Member, error)
  • func (b *Balancer) Register(servers ...server.Server)
  • func (b *Balancer) Shutdown()
  • func (b *Balancer) Validate() error
• type BalancerOption
  • func AddCustomMetrics(entries ...metrics.MetricEntry) BalancerOption
  • func EnableDiscovery(interval time.Duration, resolver resolve.Resolver) BalancerOption
  • func EnableHealthcheck(interval time.Duration, fn healthcheck.HealthcheckFn) BalancerOption
  • func WithBalancerAlgorithm(algorithm algorithm.Algorithm) BalancerOption
  • func WithFilterFnList(funcs ...filter.FilterFn) BalancerOption
  • func WithZapLogger(logger *zap.Logger) BalancerOption

Types

type Balancer

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

func New

func New(opts ...BalancerOption) (*Balancer, error)

func (*Balancer) GetMembers

func (b *Balancer) GetMembers() []*server.Member

func (*Balancer) Pick

func (b *Balancer) Pick() (*server.Member, error)

func (*Balancer) Register

func (b *Balancer) Register(servers ...server.Server)

func (*Balancer) Shutdown

func (b *Balancer) Shutdown()

func (*Balancer) Validate

func (b *Balancer) Validate() error

type BalancerOption

type BalancerOption func(*option)

func AddCustomMetrics

func AddCustomMetrics(
	entries ...metrics.MetricEntry,
) BalancerOption

func EnableDiscovery

func EnableDiscovery(
	interval time.Duration,
	resolver resolve.Resolver,
) BalancerOption

func EnableHealthcheck

func EnableHealthcheck(
	interval time.Duration,
	fn healthcheck.HealthcheckFn,
) BalancerOption

func WithBalancerAlgorithm

func WithBalancerAlgorithm(algorithm algorithm.Algorithm) BalancerOption

func WithFilterFnList

func WithFilterFnList(funcs ...filter.FilterFn) BalancerOption

func WithZapLogger

func WithZapLogger(logger *zap.Logger) BalancerOption