Versions in this module Expand all Collapse all v1 v1.0.0 Apr 10, 2023 Changes in this version + const DefaultTransactTimeout + const TransResult_Failed + const TransResult_Max + const TransResult_Success + const TransResult_TimeOut + const TransRootNodeLevel + const TransStatsOp_Commit + const TransStatsOp_Exe + const TransStatsOp_Resume + const TransStatsOp_Rollback + const TransStatsOp_Timeout + const TransStatsOp_Yiled + var Config = Configuration + var DTCModule = &transactCoordinater + var TransNodeIDNil = TransNodeID(0) + func ProcessTransCmd(tid TransNodeID, cmd TransCmd) bool + func ProcessTransResult(tid, childtid TransNodeID, retCode int, ud interface{}) bool + func ProcessTransStart(parentTnp, myTnp *TransNodeParam, ud interface{}, timeout time.Duration) bool + func RegisteHandler(tt TransType, th TransHandler) + func RegisteTxCommSkeleton(name string, tcs TransactCommSkeleton) + func SendTranscatResume(tnode *TransNode) bool + func SendTranscatYield(tnode *TransNode) bool + func Stats() map[int]TransStats + type Configuration struct + TxSkeletonName string + func (this *Configuration) Close() error + func (this *Configuration) Init() error + func (this *Configuration) Name() string + type OnChildRespWrapper func(n *TransNode, hChild TransNodeID, retCode int, ud interface{}) TransExeResult + type OnCommitWrapper func(n *TransNode) TransExeResult + type OnExecuteWrapper func(n *TransNode, ud interface{}) TransExeResult + type OnRollBackWrapper func(n *TransNode) TransExeResult + type TransBrotherNotify func(*TransNode, TransExeResult) + type TransCallback func(*TransNode) + type TransCmd int + const TransCmd_Commit + const TransCmd_Invalid + const TransCmd_RollBack + type TransCtx struct + func NewTransCtx() *TransCtx + func (this *TransCtx) GetField(k interface{}) interface{} + func (this *TransCtx) SetField(k, v interface{}) + type TransExeResult int + const TransExeResult_AsynFailed + const TransExeResult_ChildNodeNotExist + const TransExeResult_ChildNodeRepeateRet + const TransExeResult_Failed + const TransExeResult_HadDone + const TransExeResult_NoSetHandler + const TransExeResult_NoStart + const TransExeResult_NullPointer + const TransExeResult_StartChildFailed + const TransExeResult_Success + const TransExeResult_UnsafeExecuteEnv + const TransExeResult_Yield + type TransHanderWrapper struct + func (wrapper *TransHanderWrapper) OnChildTransRep(n *TransNode, hChild TransNodeID, retCode int, ud interface{}) TransExeResult + func (wrapper *TransHanderWrapper) OnCommit(n *TransNode) TransExeResult + func (wrapper *TransHanderWrapper) OnExcute(n *TransNode, ud interface{}) TransExeResult + func (wrapper *TransHanderWrapper) OnRollBack(n *TransNode) TransExeResult + type TransHandler interface + OnChildTransRep func(n *TransNode, hChild TransNodeID, retCode int, ud interface{}) TransExeResult + OnCommit func(n *TransNode) TransExeResult + OnExcute func(n *TransNode, ud interface{}) TransExeResult + OnRollBack func(n *TransNode) TransExeResult + func GetHandler(tt TransType) TransHandler + type TransNode struct + AsynCallback TransCallback + Childs map[TransNodeID]*TransNodeParam + MyTnp *TransNodeParam + ParentTnp *TransNodeParam + TransEnv *TransCtx + TransRep *TransResult + func (this *TransNode) GetChildTransParam(childid TransNodeID) *TransNodeParam + func (this *TransNode) Go(obj *basic.Object) TransExeResult + func (this *TransNode) MakeBrotherWith(brother *TransNode, tbn TransBrotherNotify) + func (this *TransNode) Resume() TransExeResult + func (this *TransNode) StartChildTrans(tnp *TransNodeParam, ud interface{}, timeout time.Duration) TransExeResult + func (this *TransNode) Yield() TransExeResult + type TransNodeID int64 + type TransNodeParam struct + AreaID int + LevelNo int + Oid int + Ot TransOwnerType + SkeletonID int + TId TransNodeID + Tct TransactCommitPolicy + TimeOut time.Duration + Tt TransType + type TransOwnerType int + const TransOwnerType_Invalid + const TransOwnerType_Max + type TransResult struct + RetCode int + RetFiels interface{} + type TransStats struct + CommitTimes int64 + ExecuteTimes int64 + MaxRuningTime int64 + ResumeTimes int64 + RollbackTimes int64 + TimeoutTimes int64 + TotalRuningTime int64 + YieldTimes int64 + type TransType int + type TransactCommSkeleton interface + GetAreaID func() int + GetSkeletonID func() int + SendCmdToTransNode func(tnp *TransNodeParam, cmd TransCmd) bool + SendTransResult func(parent, me *TransNodeParam, tr *TransResult) bool + SendTransStart func(parent, me *TransNodeParam, ud interface{}) bool + func GetTxCommSkeleton(name string) TransactCommSkeleton + type TransactCommitPolicy int + const TransactCommitPolicy_SelfDecide + const TransactCommitPolicy_TwoPhase