connpool

Documentation

Index

• type Dialer
• type InFlightConns
  • func NewInFlightConns() (*InFlightConns, error)
  • func (i *InFlightConns) Add(conn net.Conn)
  • func (i *InFlightConns) Close() error
  • func (i *InFlightConns) Remove(conn net.Conn)
• type OneTimePool
  • func NewOneTimePool(ctx context.Context, address string, poolSize int) (*OneTimePool, error)
  • func (p *OneTimePool) Acquire(c context.Context) (net.Conn, error)
  • func (p *OneTimePool) Close() error
  • func (p *OneTimePool) Run() error

Types

type Dialer

type Dialer interface {
	Dial(ctx context.Context, network, address string) (net.Conn, error)
}

type InFlightConns

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

func NewInFlightConns

func NewInFlightConns() (*InFlightConns, error)

func (*InFlightConns) Add

func (i *InFlightConns) Add(conn net.Conn)

func (*InFlightConns) Close

func (i *InFlightConns) Close() error

func (*InFlightConns) Remove

func (i *InFlightConns) Remove(conn net.Conn)

type OneTimePool

type OneTimePool struct {
	InFlightConns *InFlightConns

	Dialer Dialer
	// contains filtered or unexported fields
}

OneTimePool is a pool designed to create continous bare connections that are for one time only usage

func NewOneTimePool

func NewOneTimePool(ctx context.Context, address string, poolSize int) (*OneTimePool, error)

func (*OneTimePool) Acquire

func (p *OneTimePool) Acquire(c context.Context) (net.Conn, error)

Acquire acquires an idle connection from the pool

func (*OneTimePool) Close

func (p *OneTimePool) Close() error

func (*OneTimePool) Run

func (p *OneTimePool) Run() error