Function ExecuteInTx

client/tx.go:41–52

ExecuteInTx runs fn inside tx which should already have begun.

(tx driver.Tx, fn func() error)

// ExecuteInTx runs fn inside tx which should already have begun.
func ExecuteInTx(tx driver.Tx, fn func() error) (err error) {
	err = fn()
	if err == nil {
		err = tx.Commit()
		if err != nil {
			err = errors.Wrapf(err, "exec in tx")
		}
	} else {
		_ = tx.Rollback()
	}
	return
}