transaction

Documentation

Index

• Constants
• func CheckTx(ctx context.Context) (tx pgx.Tx, found bool)
• func CreateTx(ctx context.Context, dbc TxStarter, options pgx.TxOptions) (tx pgx.Tx, commit func(ctx context.Context) error, ...)
• type TxManager
  • func NewTransactionManager(db *pg.Client) TxManager
• type TxStarter

Constants

const (
	TxKey key = "tx"
)

Functions

func CheckTx

func CheckTx(ctx context.Context) (
	tx pgx.Tx, found bool,
)

func CreateTx

func CreateTx(ctx context.Context, dbc TxStarter, options pgx.TxOptions) (
	tx pgx.Tx,
	commit func(ctx context.Context) error,
	rollback func(ctx context.Context) error,
	err error,
)

Types

type TxManager

type TxManager interface {
	ReadCommitted(ctx context.Context, f func(ctx context.Context) error) error
}

func NewTransactionManager

func NewTransactionManager(db *pg.Client) TxManager

type TxStarter

type TxStarter interface {
	BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
}