transactor

Documentation

Index

• Variables
• type Handler
• type Store
  • func (ts *Store) Commit(ctx context.Context) error
  • func (ts *Store) GetHandler(ctx context.Context, handler Handler) (sql.Handler, bool, error)
  • func (ts *Store) RollBack(ctx context.Context) error
• type Transactor
  • func New() *Transactor
  • func (h *Transactor) GetStore() *Store
  • func (h *Transactor) Transact(ctx context.Context, txFunc func(tx context.Context) error) (err error)

Variables

var ErrTransactionHandlerNotFound = errors.New("transaction handler not found")

Types

type Handler

type Handler interface {
	sql.Handler
	sql.TransactionBeginner
}

type Store

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

func (*Store) Commit

func (ts *Store) Commit(ctx context.Context) error

func (*Store) GetHandler

func (ts *Store) GetHandler(ctx context.Context, handler Handler) (sql.Handler, bool, error)

func (*Store) RollBack

func (ts *Store) RollBack(ctx context.Context) error

type Transactor

type Transactor struct {
	TransactorStore *Store
}

func New

func New() *Transactor

func (*Transactor) GetStore

func (h *Transactor) GetStore() *Store

func (*Transactor) Transact

func (h *Transactor) Transact(ctx context.Context, txFunc func(tx context.Context) error) (err error)