wpgx

Sep 13, 2024

Changes in this version

type ReadReplicaConfig

+ Broken bool

Aug 27, 2024

Changes in this version

type Pool

+ func (p *Pool) WQuerier(name *ReplicaName) (WQuerier, error)

Aug 27, 2024

Changes in this version

+ const ReservedReplicaNamePrimary

+ var ErrReplicaNotFound = fmt.Errorf("replica not found")

type Config

+ IsProxy bool

+ ReadReplicas []ReadReplicaConfig

+ ReplicaPrefixes []string

type Pool

+ func (p *Pool) MustReplicaPool(name ReplicaName) *pgxpool.Pool

+ func (p *Pool) PingPrimary(ctx context.Context) error

+ func (p *Pool) RawPrimaryPool() *pgxpool.Pool

+ func (p *Pool) ReplicaPool(name ReplicaName) (pp *pgxpool.Pool, ok bool)

+ func (p *Pool) ReplicaPools() map[ReplicaName]*pgxpool.Pool

+ func (p *Pool) WQuerierFromReplica(name *ReplicaName) (WQuerier, error)

+ type ReadReplicaConfig struct

+ BeforeAcquire func(context.Context, *pgx.Conn) bool

+ DBName string

+ Host string

+ IsProxy bool

+ MaxConnIdleTime time.Duration

+ MaxConnLifetime time.Duration

+ MaxConns int32

+ MinConns int32

+ Name ReplicaName

+ Password string

+ Port int

+ Username string

+ type ReplicaName string

+ type WCopyFromer interface

+ WCopyFrom func(ctx context.Context, name string, tableName pgx.Identifier, ...) (int64, error)

+ type WExecer interface

+ PostExec func(f PostExecFunc) error

+ WExec func(ctx context.Context, name string, unprepared string, args ...interface{}) (pgconn.CommandTag, error)

+ type WQuerier interface

+ CountIntent func(name string)

+ WQuery func(ctx context.Context, name string, unprepared string, args ...interface{}) (pgx.Rows, error)

+ WQueryRow func(ctx context.Context, name string, unprepared string, args ...interface{}) pgx.Row

Jul 11, 2024

Changes in this version

type Config

+ BeforeAcquire func(context.Context, *pgx.Conn) bool

Aug 30, 2023

Changes in this version

type WGConn

+ CountIntent func(ctx context.Context, name string)

Aug 30, 2023

Changes in this version

type WConn

+ func (c *WConn) CountIntent(ctx context.Context, name string)

type WTx

+ func (t *WTx) CountIntent(ctx context.Context, name string)

Jan 4, 2023

Changes in this version

type WConn

+ func (c *WConn) WCopyFrom(ctx context.Context, name string, tableName pgx.Identifier, ...) (int64, error)

type WGConn

+ WCopyFrom func(ctx context.Context, name string, tableName pgx.Identifier, ...) (int64, error)

type WTx

+ func (t *WTx) WCopyFrom(ctx context.Context, name string, tableName pgx.Identifier, ...) (int64, error)

Jan 1, 2023

Changes in this version

+ const AppNameLengthMax

+ const DefaultEnvPrefix

+ const HighQPSMaxOpenConns

+ type Config struct

+ AppName string

+ DBName string

+ EnablePrometheus bool

+ EnableTracing bool

+ Host string

+ MaxConnIdleTime time.Duration

+ MaxConnLifetime time.Duration

+ MaxConns int32

+ MinConns int32

+ Password string

+ Port int

+ Username string

+ func ConfigFromEnv() *Config

+ func ConfigFromEnvPrefix(prefix string) *Config

+ func (c *Config) String() string

+ func (c *Config) Valid() error

+ type Pool struct

+ func NewPool(ctx context.Context, config *Config) (*Pool, error)

+ func (p *Pool) Close()

+ func (p *Pool) Ping(ctx context.Context) error

+ func (p *Pool) RawPool() *pgxpool.Pool

+ func (p *Pool) Transact(ctx context.Context, txOptions pgx.TxOptions, fn TxFunc) (resp interface{}, err error)

+ func (p *Pool) WConn() *WConn

+ type PostExecFunc = func() error

+ type TxFunc = func(WGConn) (any, error)

+ type WConn struct

+ func (c *WConn) PostExec(fn PostExecFunc) error

+ func (c *WConn) WExec(ctx context.Context, name string, unprepared string, args ...interface{}) (pgconn.CommandTag, error)

+ func (c *WConn) WQuery(ctx context.Context, name string, unprepared string, args ...interface{}) (pgx.Rows, error)

+ func (c *WConn) WQueryRow(ctx context.Context, name string, unprepared string, args ...interface{}) pgx.Row

+ type WGConn interface

+ PostExec func(f PostExecFunc) error

+ WExec func(ctx context.Context, name string, unprepared string, args ...interface{}) (pgconn.CommandTag, error)

+ WQuery func(ctx context.Context, name string, unprepared string, args ...interface{}) (pgx.Rows, error)

+ WQueryRow func(ctx context.Context, name string, unprepared string, args ...interface{}) pgx.Row

+ type WTx struct

+ func (t *WTx) Commit(ctx context.Context) error

+ func (t *WTx) PostExec(f PostExecFunc) error

+ func (t *WTx) Rollback(ctx context.Context) error

+ func (t *WTx) WExec(ctx context.Context, name string, unprepared string, args ...interface{}) (pgconn.CommandTag, error)

+ func (t *WTx) WQuery(ctx context.Context, name string, unprepared string, args ...interface{}) (pgx.Rows, error)

+ func (t *WTx) WQueryRow(ctx context.Context, name string, unprepared string, args ...interface{}) pgx.Row