pool

Nov 14, 2025

retracted

Changes in this version

+ var ErrConnectionInvalid = errors.New("connection is invalid")

+ var ErrPoolClosed = errors.New("connection pool is closed")

+ var ErrPoolExhausted = errors.New("connection pool exhausted")

+ type Config struct

+ MaxIdle int

+ MaxIdleTime time.Duration

+ MaxLifetime time.Duration

+ MaxOpen int

+ WaitTimeout time.Duration

+ func DefaultConfig() Config

+ type Connection interface

+ Close func() error

+ IsValid func() bool

+ Reset func() error

+ type Factory interface

+ Create func() (Connection, error)

+ Validate func(conn Connection) bool

+ type Pool struct

+ func NewPool(factory Factory, config Config) *Pool

+ func (p *Pool) CleanupStale() int

+ func (p *Pool) Close() error

+ func (p *Pool) Get(ctx context.Context) (Connection, error)

+ func (p *Pool) GetMetrics() *metrics.Metrics

+ func (p *Pool) Put(conn Connection) error

+ func (p *Pool) StartCleaner(interval time.Duration) chan struct{}

+ func (p *Pool) Stats() PoolStats

+ type PoolStats struct

+ IdleConnections int

+ MaxIdleConns int

+ MaxOpenConns int

+ OpenConnections int

+ WaitingRequests int