lb

Documentation

Index

• type LBFactory
  • func NewLBFactory(geoLoc *geolocs.GeoLoc) *LBFactory
  • func (f *LBFactory) MakeLb(entry *entries.Entry, algo entries.LBAlgo) Loadbalancer
• type Loadbalancer
• type MemberType
• type Random
  • func NewRandom(entry *entries.Entry) *Random
  • func (rtd *Random) Name() string
  • func (rtd *Random) Next(_ context.Context, memberType MemberType) (*entries.Member, error)
  • func (rtd *Random) Reset() error
• type RoundRobin
  • func NewRoundRobin(entry *entries.Entry) *RoundRobin
  • func (rr *RoundRobin) Name() string
  • func (rr *RoundRobin) Next(_ context.Context, memberType MemberType) (*entries.Member, error)
  • func (rr *RoundRobin) Reset() error
• type Topology
  • func NewTopology(entry *entries.Entry, geoLoc *geolocs.GeoLoc) *Topology
  • func (t *Topology) Name() string
  • func (t *Topology) Next(ctx context.Context, memberType MemberType) (*entries.Member, error)
  • func (t *Topology) Reset() error
• type WeightedRoundRobin
  • func NewWeightedRoundRobin(entry *entries.Entry) *WeightedRoundRobin
  • func (wrr *WeightedRoundRobin) Name() string
  • func (wrr *WeightedRoundRobin) Next(_ context.Context, memberType MemberType) (*entries.Member, error)
  • func (wrr *WeightedRoundRobin) Reset() error

Types

type LBFactory

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

func NewLBFactory

func NewLBFactory(geoLoc *geolocs.GeoLoc) *LBFactory

func (*LBFactory) MakeLb

func (f *LBFactory) MakeLb(entry *entries.Entry, algo entries.LBAlgo) Loadbalancer

type Loadbalancer

type Loadbalancer interface {
	Next(ctx context.Context, memberType MemberType) (*entries.Member, error)
	Reset() error

	Name() string
}

type MemberType

type MemberType int

const (
	All MemberType = iota
	Ipv4
	Ipv6
)

type Random

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

func NewRandom

func NewRandom(entry *entries.Entry) *Random

func (*Random) Name

func (rtd *Random) Name() string

func (*Random) Next

func (rtd *Random) Next(_ context.Context, memberType MemberType) (*entries.Member, error)

func (*Random) Reset

func (rtd *Random) Reset() error

type RoundRobin

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

func NewRoundRobin

func NewRoundRobin(entry *entries.Entry) *RoundRobin

func (*RoundRobin) Name

func (rr *RoundRobin) Name() string

func (*RoundRobin) Next

func (rr *RoundRobin) Next(_ context.Context, memberType MemberType) (*entries.Member, error)

func (*RoundRobin) Reset

func (rr *RoundRobin) Reset() error

type Topology

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

func NewTopology

func NewTopology(entry *entries.Entry, geoLoc *geolocs.GeoLoc) *Topology

func (*Topology) Name

func (t *Topology) Name() string

func (*Topology) Next

func (t *Topology) Next(ctx context.Context, memberType MemberType) (*entries.Member, error)

func (*Topology) Reset

func (t *Topology) Reset() error

type WeightedRoundRobin

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

func NewWeightedRoundRobin

func NewWeightedRoundRobin(entry *entries.Entry) *WeightedRoundRobin

func (*WeightedRoundRobin) Name

func (wrr *WeightedRoundRobin) Name() string

func (*WeightedRoundRobin) Next

func (wrr *WeightedRoundRobin) Next(_ context.Context, memberType MemberType) (*entries.Member, error)

func (*WeightedRoundRobin) Reset

func (wrr *WeightedRoundRobin) Reset() error