Versions in this module Expand all Collapse all v1 v1.0.4 Jul 25, 2025 v1.0.3 Jul 11, 2025 v1.0.2 Jul 1, 2025 v1.0.1 Jul 1, 2025 v1.0.0 Jun 26, 2025 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 + ExpiresTs int64 + 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
Go to main page