balancer

Documentation

Index

• func IsOkConnection(c conn.Conn, bannedIsOk bool) bool
• type Balancer
• type NextOption
  • func WithAcceptBanned(val bool) NextOption
  • func WithOnBadState(callback OnBadStateCallback) NextOption
• type NextOptions
  • func MakeNextOptions(opts ...NextOption) NextOptions
  • func (o *NextOptions) Discovery(ctx context.Context)
• type OnBadStateCallback

Functions

func IsOkConnection

func IsOkConnection(c conn.Conn, bannedIsOk bool) bool

Types

type Balancer

type Balancer interface {
	// Next returns next connection for request.
	Next(ctx context.Context, opts ...NextOption) conn.Conn

	// Create same balancer instance with new connections
	Create(conns []conn.Conn) Balancer
}

Balancer is an interface that implements particular load-balancing algorithm.

Balancer methods called synchronized. That is, implementations must not provide additional goroutine safety.

type NextOption

type NextOption func(o *NextOptions)

func WithAcceptBanned

func WithAcceptBanned(val bool) NextOption

func WithOnBadState

func WithOnBadState(callback OnBadStateCallback) NextOption

type NextOptions

type NextOptions struct {
	OnBadState   OnBadStateCallback
	AcceptBanned bool
}

func MakeNextOptions

func MakeNextOptions(opts ...NextOption) NextOptions

func (*NextOptions) Discovery

func (o *NextOptions) Discovery(ctx context.Context)

type OnBadStateCallback

type OnBadStateCallback func(ctx context.Context)