transactor

Documentation

Index

• func ExtractTx(ctx context.Context) *sqlx.Tx
• func InjectTx(ctx context.Context, tx *sqlx.Tx) context.Context
• type Transactor
  • func New(db *sqlx.DB) *Transactor
  • func (tr *Transactor) WithinTransaction(ctx context.Context, f func(ctx context.Context) error) error

Functions

func ExtractTx

func ExtractTx(ctx context.Context) *sqlx.Tx

func InjectTx

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

Types

type Transactor

type Transactor struct {
	// contains filtered or unexported fields
}

func New

func New(db *sqlx.DB) *Transactor

func (*Transactor) WithinTransaction

func (tr *Transactor) WithinTransaction(
	ctx context.Context,
	f func(ctx context.Context) error,
) error

TODO: add transaction options