transactor

Documentation

Index

• type DBTransactor
  • func NewDBTransactor(db *sql.DB) *DBTransactor
  • func (rtx *DBTransactor) Begin(ctx context.Context) (context.Context, error)
  • func (rtx *DBTransactor) Commit(ctx context.Context) error
  • func (rtx *DBTransactor) GetTransactionFromCtx(ctx context.Context) (*sql.Tx, bool)
  • func (rtx *DBTransactor) Rollback(ctx context.Context) error

Types

type DBTransactor

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

func NewDBTransactor

func NewDBTransactor(db *sql.DB) *DBTransactor

func (*DBTransactor) Begin

func (rtx *DBTransactor) Begin(ctx context.Context) (context.Context, error)

func (*DBTransactor) Commit

func (rtx *DBTransactor) Commit(ctx context.Context) error

func (*DBTransactor) GetTransactionFromCtx

func (rtx *DBTransactor) GetTransactionFromCtx(ctx context.Context) (*sql.Tx, bool)

func (*DBTransactor) Rollback

func (rtx *DBTransactor) Rollback(ctx context.Context) error