connpool

package

v0.0.47 Latest Latest Go to latest Published: Oct 31, 2023 License: MIT Imports: 6 Imported by: 3

Details

This section is empty.

This section is empty.

This section is empty.

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

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

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 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(ctx context.Context, address string, poolSize int) (*OneTimePool, error)

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

Acquire acquires an idle connection from the pool

func (p *OneTimePool) Close() error

func (p *OneTimePool) Run() error