Versions in this module Expand all Collapse all v0 v0.0.1 Apr 16, 2020 Changes in this version + func Execute(fn func() error) (err error) + func ExecuteInTx(ctx context.Context, tx Tx, fn func() error) (err error) + func ExecuteTx(ctx context.Context, trx Transactor, opts *sql.TxOptions, ...) error + func ExecuteTxGenericTest(ctx context.Context, framework WriteSkewTest) error + func Unwrap(err error) error + type AmbiguousCommitError struct + func (e *AmbiguousCommitError) Cause() error + func (e *AmbiguousCommitError) Error() string + type ErrorCauser interface + Cause func() error + type Transactor interface + BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) + type Tx interface + Commit func(context.Context) error + Exec func(context.Context, string, ...interface{}) error + Rollback func(context.Context) error + type TxnRestartError struct + func (e *TxnRestartError) Cause() error + func (e *TxnRestartError) Error() string + func (e *TxnRestartError) RetryCause() error + type UnwrappableError interface + Unwrap func() error + type WriteSkewTest interface + ExecuteTx func(ctx context.Context, fn func(tx interface{}) error) error + GetBalances func(ctx context.Context, tx interface{}) (bal1, bal2 int, err error) + Init func(context.Context) error + UpdateBalance func(ctx context.Context, tx interface{}, acct, delta int) error
Go to main page