Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

transact

package

Go to main page

Versions in this module

v1

v1.0.5

Jun 24, 2026

Changes in this version

+ const TransStatsOp_Yield

+ func SendTransactResume(tnode *TransNode) bool

+ func SendTransactYield(tnode *TransNode) bool

+ type TransHandlerWrapper struct

+ func (wrapper *TransHandlerWrapper) OnChildTransRep(n *TransNode, hChild TransNodeID, retCode int, ud interface{}) TransExeResult

+ func (wrapper *TransHandlerWrapper) OnCommit(n *TransNode) TransExeResult

+ func (wrapper *TransHandlerWrapper) OnExcute(n *TransNode, ud interface{}) TransExeResult

+ func (wrapper *TransHandlerWrapper) OnRollBack(n *TransNode) TransExeResult

type TransResult

+ RetFields interface{}

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