Method BeginTx

server/transaction_commit_informer.go:56–62

BeginTx wraps transaction object with sync

(ctx context.Context, options *transaction.TxOptions)

// BeginTx wraps transaction object with sync
func (sw *DbSyncWrapper) BeginTx(ctx context.Context, options *transaction.TxOptions) (transaction.Transaction, error) {
	tx, err := sw.DB.BeginTx(ctx, options)
	if err != nil {
		return nil, err
	}
	return syncTransactionWrap(tx), nil
}

type transactionEventLogger struct {
	transaction.Transaction