startup_postgres

Jul 4, 2019

Changes in this version

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

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

type TxHelper

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

Mar 26, 2019

Changes in this version

+ var WithTransactionContext = func(ctx context.Context, db TxStarter, operation TransactionFn) (err 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 TransactionFn) error

+ type TxStarter interface

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

Mar 25, 2019

Changes in this version

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

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

+ func NewTransactionContext(ctx context.Context, db BeginTxer, operation TransactionFn) (err error)

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

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

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

Mar 25, 2019

Changes in this version

+ type BeginTxer interface

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

+ Beginx func() (*sqlx.Tx, error)

Mar 22, 2019

Changes in this version

type Helper

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

Mar 22, 2019

Changes in this version

+ func ErrIsForeignKeyViolation(err error) bool

+ func ErrIsUniqueViolation(err error) bool

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

+ type Helper struct

+ func New(db *sqlx.DB, loggingPrefix, tracingServiceName string) Helper

+ 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