Versions in this module Expand all Collapse all v0 v0.1.0 Aug 17, 2024 Changes in this version + func Connect(logger *slog.Logger, dsn string, maxConns int, maxIdleTime string, ...) (*pgxpool.Pool, error) + func PgxErrorToHTTPError(err error) error + type DB interface + Begin func(ctx context.Context) (pgx.Tx, error) + Exec func(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) + Ping func(ctx context.Context) error + Query func(ctx context.Context, sql string, optionsAndArgs ...any) (pgx.Rows, error) + QueryRow func(ctx context.Context, sql string, optionsAndArgs ...any) pgx.Row + type PgxSyncRow struct + func (row *PgxSyncRow) Scan(dest ...any) error + type PgxSyncRows struct + func (rows *PgxSyncRows) Close() + func (rows *PgxSyncRows) CommandTag() pgconn.CommandTag + func (rows *PgxSyncRows) Conn() *pgx.Conn + func (rows *PgxSyncRows) Err() error + func (rows *PgxSyncRows) FieldDescriptions() []pgconn.FieldDescription + func (rows *PgxSyncRows) Next() bool + func (rows *PgxSyncRows) RawValues() [][]byte + func (rows *PgxSyncRows) Scan(dest ...any) error + func (rows *PgxSyncRows) Values() ([]any, error) + type PgxSyncTx struct + func CreatePgxSyncTx(ctx context.Context, db DB) *PgxSyncTx + func (tx *PgxSyncTx) Begin(ctx context.Context) (pgx.Tx, error) + func (tx *PgxSyncTx) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error) + func (tx *PgxSyncTx) Ping(ctx context.Context) error + func (tx *PgxSyncTx) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error) + func (tx *PgxSyncTx) QueryRow(ctx context.Context, sql string, args ...any) pgx.Row + func (tx *PgxSyncTx) Rollback(ctx context.Context) error + type SpanDB struct + DB DB + func NewSpanDB(db DB) SpanDB + func (db SpanDB) Begin(ctx context.Context) (pgx.Tx, error) + func (db SpanDB) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) + func (db SpanDB) Ping(ctx context.Context) error + func (db SpanDB) Query(ctx context.Context, sql string, optionsAndArgs ...any) (pgx.Rows, error) + func (db SpanDB) QueryRow(ctx context.Context, sql string, optionsAndArgs ...any) pgx.Row Other modules containing this package github.com/xdoubleu/essentia/v2 github.com/xdoubleu/essentia/v3
Go to main page