Versions in this module Expand all Collapse all v0 v0.2.0 Jul 6, 2024 v0.1.0 Jun 27, 2024 Changes in this version + const MaxConnectionPoolSize + var ErrPoolClosed = app.Err(app.ErrCodeUnknown, "pool is closed already") + type Pool struct + func NewPool(connector db.DBConnector, seedList []db.Addr, options ...PoolOption) (*Pool, error) + func (p *Pool) Acquire(ctx context.Context, credentials qc.Credentials) (conn *PoolSlot, err error) + func (p *Pool) Close() error + func (p *Pool) Drop(conn *PoolSlot) error + func (p *Pool) Release(conn *PoolSlot) error + type PoolOption func(pool *Pool) error + func WithFailBack(delay time.Duration) PoolOption + func WithLogger(log *app.Logger) PoolOption + func WithMaxSize(maxSize int) PoolOption + func WithRandomFailOver() PoolOption + type PoolSlot struct + func (s *PoolSlot) Exec(ctx context.Context, query models.Query) (rows models.RowSet, affectedRows int, err error)
Go to main page