pgxpool

Oct 22, 2025

Changes in this version

type DefaultHandler

+ func (d *DefaultHandler) IsConnected() bool

type Handler

+ IsConnected func() bool

+ type TransactionFn func(ctx context.Context, tx pgx.Tx) error

Oct 14, 2025

Changes in this version

type Config

+ func NewConfig(dataSourceName string, maxOpenConnections, maxIdleConnections int, ...) (*Config, error)

+ type DefaultHandler struct

+ func NewDefaultHandler(config *Config) (*DefaultHandler, error)

+ func (d *DefaultHandler) Connect() (*pgxpool.Pool, error)

+ func (d *DefaultHandler) Disconnect()

+ func (d *DefaultHandler) Pool() (*pgxpool.Pool, error)

+ type Handler interface

+ Connect func() (*pgxpool.Pool, error)

+ Disconnect func()

+ Pool func() (*pgxpool.Pool, error)

Oct 4, 2025

Changes in this version

+ type TransactionWithCtxFn func(ctx context.Context, tx pgx.Tx) error

Jan 28, 2025

Changes in this version

type DefaultService

+ func (d *DefaultService) ClearStatTicker()

+ func (d *DefaultService) SetStatTicker(duration time.Duration, fn func(*pgxpool.Stat))

type Service

+ ClearStatTicker func()

+ SetStatTicker func(duration time.Duration, fn func(*pgxpool.Stat))

Jan 28, 2025

Changes in this version

type DefaultService

+ func (d *DefaultService) Query(query *string, params ...interface{}) (pgx.Rows, error)

+ func (d *DefaultService) QueryWithCtx(ctx context.Context, query *string, params ...interface{}) (pgx.Rows, error)

type Service

+ Query func(query *string, params ...interface{}) (pgx.Rows, error)

+ QueryWithCtx func(ctx context.Context, query *string, params ...interface{}) (pgx.Rows, error)

Jan 28, 2025

Changes in this version

+ func CreateTransaction(pool *pgxpool.Pool, fn func(tx pgx.Tx) error) error

+ func CreateTransactionWithCtx(ctx context.Context, pool *pgxpool.Pool, fn func(tx pgx.Tx) error) error

+ type Config interface

+ ConnectionMaxIdleTime func() time.Duration

+ ConnectionMaxLifetime func() time.Duration

+ ConnectionMaxLifetimeJitter func() time.Duration

+ DataSourceName func() string

+ HealthCheckPeriod func() time.Duration

+ MaxIdleConnections func() int

+ MaxOpenConnections func() int

+ ParsedConfig func() (*pgxpool.Config, error)

+ type DefaultPoolHandler struct

+ func NewDefaultPoolHandler(config Config) (*DefaultPoolHandler, error)

+ func (d *DefaultPoolHandler) Connect() (*pgxpool.Pool, error)

+ func (d *DefaultPoolHandler) Disconnect()

+ func (d *DefaultPoolHandler) Pool() (*pgxpool.Pool, error)

+ type DefaultService struct

+ func NewDefaultService(pool *pgxpool.Pool) (instance *DefaultService, err error)

+ func (d *DefaultService) CreateTransaction(fn func(tx pgx.Tx) error) error

+ func (d *DefaultService) CreateTransactionWithCtx(ctx context.Context, fn func(tx pgx.Tx) error) error

+ func (d *DefaultService) Exec(query *string, params ...interface{}) (*pgconn.CommandTag, error)

+ func (d *DefaultService) ExecWithCtx(ctx context.Context, query *string, params ...interface{}) (*pgconn.CommandTag, error)

+ func (d *DefaultService) Migrate(queries ...string) error

+ func (d *DefaultService) Pool() *pgxpool.Pool

+ func (d *DefaultService) QueryRow(query *string, params ...interface{}) pgx.Row

+ func (d *DefaultService) QueryRowWithCtx(ctx context.Context, query *string, params ...interface{}) pgx.Row

+ func (d *DefaultService) ScanRow(row pgx.Row, destinations ...interface{}) error

+ type PoolConfig struct

+ func NewPoolConfig(dataSourceName string, maxOpenConnections, maxIdleConnections int, ...) (*PoolConfig, error)

+ func (p *PoolConfig) ConnectionMaxIdleTime() time.Duration

+ func (p *PoolConfig) ConnectionMaxLifetime() time.Duration

+ func (p *PoolConfig) ConnectionMaxLifetimeJitter() time.Duration

+ func (p *PoolConfig) DataSourceName() string

+ func (p *PoolConfig) HealthCheckPeriod() time.Duration

+ func (p *PoolConfig) MaxIdleConnections() int

+ func (p *PoolConfig) MaxOpenConnections() int

+ func (p *PoolConfig) ParsedConfig() (*pgxpool.Config, error)

+ type PoolHandler interface

+ Connect func() (*sql.DB, error)

+ Disconnect func()

+ Pool func() (*pgxpool.Pool, error)

+ type Service interface

+ CreateTransaction func(fn func(tx pgx.Tx) error) error

+ CreateTransactionWithCtx func(ctx context.Context, fn func(ctx context.Context, tx pgx.Tx) error) error

+ Exec func(query *string, params ...interface{}) (*pgconn.CommandTag, error)

+ ExecWithCtx func(ctx context.Context, query *string, params ...interface{}) (*pgconn.CommandTag, error)

+ Migrate func(queries ...string) error

+ Pool func() *pgxpool.Pool

+ QueryRow func(query *string, params ...interface{}) pgx.Row

+ QueryRowWithCtx func(ctx context.Context, query *string, params ...interface{}) pgx.Row

+ ScanRow func(row *sql.Row, destinations ...interface{}) error