txmanager

type Manager ¶

type Manager struct{}

func New() *Manager

func (m *Manager) Do(ctx context.Context, db TxStarter, fn TxFunc) (err error)

type TxFunc ¶

type TxFunc func(t pgx.Tx) error

type TxManager ¶

type TxManager interface {
	Do(ctx context.Context, starter TxStarter, fn TxFunc) error
}

TxManager for spawning new txs.

type TxStarter ¶

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

TxStarter must implement new transaction spawn.