startup_postgres

Nov 3, 2022

Changes in this version

+ func InstallTracer(tracer Tracer)

+ type Tracer interface

+ TransactionEnd func(ctx context.Context)

+ TransactionStart func(ctx context.Context) context.Context

+ func GetTracer() Tracer

Sep 20, 2022

Changes in this version

+ var ErrTransactionExistInContext = errors.New("transaction already exists in context")

+ func ExecuteInAnyTransaction(ctx context.Context, db TxStarter, ...) (R, error)

+ func ExecuteInExistingTransaction(ctx context.Context, fun func(context.Context, *sqlx.Tx) (R, error)) (R, error)

+ func ExecuteInNewTransaction(ctx context.Context, db TxStarter, ...) (R, error)

+ func GetContext(ctx context.Context, tx sqlx.QueryerContext, query string, args ...interface{}) (T, error)

+ func GetContextOrNull(ctx context.Context, tx sqlx.QueryerContext, query string, args ...interface{}) (*T, error)

+ func NoRollback(err error) error

Apr 6, 2021

Changes in this version

+ func Use(middleware Middleware)

+ type Middleware func(driver.Driver) driver.Driver

May 19, 2020

Changes in this version

+ func GuessDriverName() string

Feb 11, 2020

Changes in this version

+ var ErrNoTransaction = errors.New("no transaction in context")

+ var WithTransactionContext = func(ctx context.Context, db TxStarter, operation TransactionCommitFn) (err error)

+ func ContextWithTransaction(ctx context.Context, tx *sqlx.Tx) context.Context

+ func ErrIsForeignKeyViolation(err error) bool

+ func ErrIsUniqueViolation(err error) bool

+ func TransactionFromContext(ctx context.Context) *sqlx.Tx

+ func WithTransaction(db TxStarter, fn func(tx *sqlx.Tx) error) (err error)

+ func WithTransactionAutoCommitContext(ctx context.Context, db TxStarter, operation TransactionFn) (err error)

+ func WithTransactionFromContext(ctx context.Context, operation func(tx *sqlx.Tx) error) error

+ type Initializer func(db *sqlx.DB) error

+ func DefaultMigration(table string) Initializer

+ func Migration(table, directory string) Initializer

+ type PostgresOptions struct

+ ConnectionLifetime time.Duration

+ Inputs struct{ ... }

+ PoolSize int

+ URL string

+ func (opts *PostgresOptions) Connection() *sqlx.DB

+ func (opts *PostgresOptions) StartVacuumTask(db *sqlx.DB, table string, interval time.Duration, clock clock.Clock) io.Closer

+ type TransactionCommitFn func(ctx context.Context, tx *sqlx.Tx) (commit bool, err error)

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

+ type TxHelper struct

+ func NewTxHelper(db *sqlx.DB) TxHelper

+ func (h *TxHelper) WithTransaction(fn func(tx *sqlx.Tx) error) (err error)

+ func (h *TxHelper) WithTransactionContext(ctx context.Context, operation TransactionCommitFn) error

+ func (h *TxHelper) WithTransactionContextAutoCommit(ctx context.Context, operation TransactionFn) error

+ type TxStarter interface

+ BeginTxx func(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)