txn_pgx

Documentation

Index

• func PgxExecute[D txn.Doer[Txn, PgxBeginner]](ctx context.Context, db PgxBeginner, do D, fn txn.DoFunc[Txn, PgxBeginner, D]) (D, error)
• type PgxBeginner
• type PgxDoerBase
  • func (d *PgxDoerBase) IsReadOnly() bool
• type PgxOptions
• type PgxTx
• type PgxTxn
  • func PgxBeginTxn(ctx context.Context, db PgxBeginner, opt PgxOptions) (*PgxTxn, error)
  • func (w *PgxTxn) Commit(ctx context.Context) error
  • func (w *PgxTxn) IsNil() bool
  • func (w *PgxTxn) Rollback(ctx context.Context) error
• type Txn

Functions

func PgxExecute

func PgxExecute[D txn.Doer[Txn, PgxBeginner]](
	ctx context.Context, db PgxBeginner, do D, fn txn.DoFunc[Txn, PgxBeginner, D]) (D, error)

Types

type PgxBeginner

type PgxBeginner = *pgxpool.Pool

type PgxDoerBase

type PgxDoerBase struct {
	txn.DoerBase[PgxOptions]
}

func (*PgxDoerBase) IsReadOnly

func (d *PgxDoerBase) IsReadOnly() bool

type PgxOptions

type PgxOptions = *pgx.TxOptions

type PgxTx

type PgxTx = pgx.Tx

type PgxTxn

type PgxTxn struct {
	Raw PgxTx
}

func PgxBeginTxn

func PgxBeginTxn(ctx context.Context, db PgxBeginner, opt PgxOptions) (*PgxTxn, error)

func (*PgxTxn) Commit

func (w *PgxTxn) Commit(ctx context.Context) error

func (*PgxTxn) IsNil

func (w *PgxTxn) IsNil() bool

func (*PgxTxn) Rollback

func (w *PgxTxn) Rollback(ctx context.Context) error

type Txn

type Txn = txn.Txn