connpool

README

= connpool
Connection pool to enforce max duration & delay between commands

Documentation

Index

• type Conn
  • func Wrap(c net.Conn) Conn
• type Logger
• type NewConnectionFunc
• type Pool
  • func (p *Pool) Do(ctx context.Context, work Work) error
• type Work

Types

type Conn

type Conn interface {
	net.Conn

	ReadWriter() *bufio.ReadWriter
	EmptyReadBuffer(deadline time.Time) ([]byte, error)
	ReadUntil(delim byte, deadline time.Time) ([]byte, error)
}

Conn .

func Wrap

func Wrap(c net.Conn) Conn

Wrap .

type Logger

type Logger interface {
	Debugf(format string, a ...interface{})
	Infof(format string, a ...interface{})
	Warnf(format string, a ...interface{})
	Errorf(format string, a ...interface{})
}

type NewConnectionFunc

type NewConnectionFunc func(context.Context) (net.Conn, error)

type Pool

type Pool struct {
	NewConnection NewConnectionFunc
	TTL           time.Duration
	Delay         time.Duration
	Logger        Logger
	// contains filtered or unexported fields
}

func (*Pool) Do

func (p *Pool) Do(ctx context.Context, work Work) error

type Work

type Work func(Conn) error