pg

May 26, 2025

Changes in this version

+ var ErrGlobalPoolNotInitialized = errors.New("global pgx pool is not initialized")

+ var ErrInvalidPool = errors.New("provided pgx pool is not the global pool")

+ func SetupGlobalPgxPool(pool *pgxpool.Pool)

Apr 15, 2025

Changes in this version

+ var ErrAlreadyInTx = errors.New("already executing in existing db tx")

+ var ErrNotInTx = errors.New("not executing in existing db tx")

+ func CheckNoRows(inErr, outErr error) error

+ func CheckUniqueViolation(inErr, outErr error) error

+ func Decode(value string) ([]byte, error)

+ func Encode(value []byte, encodeType ...EncodeType) string

+ func ExecuteInTx(ctx context.Context, db *sqlx.DB, isolation sql.IsolationLevel, ...) (err error)

+ func ExecuteRetryable(fn func() error) error

+ func ExecuteTxWithinCtx(ctx context.Context, db *sqlx.DB, isolation sql.IsolationLevel, ...) error

+ func IsUniqueViolation(err error) bool

+ func NewWithAwsIam(username, hostname, port, dbname string, config aws.Config) (*sql.DB, error)

+ func NewWithUsernameAndPassword(username, password, hostname, port, dbname string) (*sql.DB, error)

+ type Config struct

+ DbName string

+ Host string

+ MaxIdleConnections int

+ MaxOpenConnections int

+ Password string

+ Port int

+ User string

+ type EncodeType string

+ const Base58

+ const Base64

+ const DefaultEncodeType

+ const Hex