dial

Documentation

Index

• Variables
• type LimitDialer
  • func NewLimitDialer(limit int64, readTimeout, dialTimeout time.Duration) *LimitDialer
  • func (d *LimitDialer) Dial(network, addr string) (c net.Conn, err error)
  • func (d *LimitDialer) DropEndpoint(endpoint string)

Variables

var ErrSlowOrMaintained = fmt.Errorf("Slow or maintained endpoint")

ErrSlowOrMaintained is returned if LimitDialer exceeds connection limit

Types

type LimitDialer

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

LimitDialer limits open connections by read and dial timeout. Also provides hard limit on number of open connections

func NewLimitDialer

func NewLimitDialer(limit int64, readTimeout, dialTimeout time.Duration) *LimitDialer

NewLimitDialer returns new `LimitDialer`.

func (*LimitDialer) Dial

func (d *LimitDialer) Dial(network, addr string) (c net.Conn, err error)

Dial connects to endpoint as net.Dial does, but also keeps track on number of connections

func (*LimitDialer) DropEndpoint

func (d *LimitDialer) DropEndpoint(endpoint string)

DropEndpoint marks backend as dropped i.e. maintenance x