proxy_tx

Documentation

Index

• type ProxyTx
  • func (tx *ProxyTx) AppendLockKey(lockKey string)
  • func (tx *ProxyTx) AppendUndoLog(undoLog *undo.SqlUndoLog)
  • func (tx *ProxyTx) Bind(xid string)
  • func (tx *ProxyTx) GetResourceId() string
  • func (tx *ProxyTx) IsGlobalLockRequire() bool
  • func (tx *ProxyTx) SetGlobalLockRequire(isLock bool)
• type TxContext
  • func NewTxContext(ctx *context.RootContext) *TxContext
  • func (ctx *TxContext) AppendLockKey(lockKey string)
  • func (ctx *TxContext) AppendUndoItem(sqlUndoLog *undo.SqlUndoLog)
  • func (ctx *TxContext) Bind(xid string)
  • func (ctx *TxContext) BuildLockKeys() string
  • func (ctx *TxContext) HasUndoLog() bool
  • func (ctx *TxContext) InGlobalTransaction() bool
  • func (ctx *TxContext) IsBranchRegistered() bool
  • func (ctx *TxContext) Reset()

Types

type ProxyTx

type ProxyTx struct {
	*sql.Tx
	DSN        string
	ResourceId string
	Context    *TxContext
}

func (*ProxyTx) AppendLockKey

func (tx *ProxyTx) AppendLockKey(lockKey string)

func (*ProxyTx) AppendUndoLog

func (tx *ProxyTx) AppendUndoLog(undoLog *undo.SqlUndoLog)

func (*ProxyTx) Bind

func (tx *ProxyTx) Bind(xid string)

func (*ProxyTx) GetResourceId

func (tx *ProxyTx) GetResourceId() string

func (*ProxyTx) IsGlobalLockRequire

func (tx *ProxyTx) IsGlobalLockRequire() bool

func (*ProxyTx) SetGlobalLockRequire

func (tx *ProxyTx) SetGlobalLockRequire(isLock bool)

type TxContext

type TxContext struct {
	*context.RootContext
	Xid                 string
	BranchId            int64
	IsGlobalLockRequire bool

	LockKeysBuffer     *model.Set
	SqlUndoItemsBuffer []*undo.SqlUndoLog
}

func NewTxContext

func NewTxContext(ctx *context.RootContext) *TxContext

func (*TxContext) AppendLockKey

func (ctx *TxContext) AppendLockKey(lockKey string)

func (*TxContext) AppendUndoItem

func (ctx *TxContext) AppendUndoItem(sqlUndoLog *undo.SqlUndoLog)

func (*TxContext) Bind

func (ctx *TxContext) Bind(xid string)

func (*TxContext) BuildLockKeys

func (ctx *TxContext) BuildLockKeys() string

func (*TxContext) HasUndoLog

func (ctx *TxContext) HasUndoLog() bool

func (*TxContext) InGlobalTransaction

func (ctx *TxContext) InGlobalTransaction() bool

func (*TxContext) IsBranchRegistered

func (ctx *TxContext) IsBranchRegistered() bool

func (*TxContext) Reset

func (ctx *TxContext) Reset()