balancer

Jun 7, 2023

Changes in this version

+ const NetworkConnect

+ const NetworkPersistent

+ type Balancer struct

+ HasSucceedingDialer <-chan bool

+ func New(allowBackgroundChecking func() bool, overallDialTimeout time.Duration, ...) *Balancer

+ func (b *Balancer) Close()

+ func (b *Balancer) DialContext(ctx context.Context, network, addr string) (net.Conn, error)

+ func (b *Balancer) KeepLookingForSucceedingDialer()

+ func (b *Balancer) OnActiveDialer() <-chan Dialer

+ func (b *Balancer) Reset(dialers []Dialer)

+ func (b *Balancer) ResetFromExisting()

+ type Dialer interface

+ Addr func() string

+ Attempts func() int64

+ ConsecFailures func() int64

+ ConsecSuccesses func() int64

+ DataRecv func() uint64

+ DataSent func() uint64

+ DialContext func(ctx context.Context, network, addr string) (conn net.Conn, failedUpstream bool, err error)

+ EstBandwidth func() float64

+ EstRTT func() time.Duration

+ EstSuccessRate func() float64

+ Failures func() int64

+ JustifiedLabel func() string

+ Label func() string

+ Location func() (string, string, string)

+ MarkFailure func()

+ Name func() string

+ NumPreconnected func() int

+ NumPreconnecting func() int

+ Probe func(forPerformance bool) bool

+ ProbeStats func() (successes uint64, successKBs uint64, failures uint64, failedKBs uint64)

+ Protocol func() string

+ Stop func()

+ Succeeding func() bool

+ Successes func() int64

+ SupportsAddr func(network, addr string) bool

+ Trusted func() bool

+ WriteStats func(w io.Writer)

+ func SortDialers(dialers []Dialer) []Dialer