tm

type DefaultGlobalTransaction struct {
	XID    string
	Status api.GlobalSession_GlobalStatus
	Role   GlobalTransactionRole
	// contains filtered or unexported fields
}

type GlobalTransaction interface {
	Begin(ctx *ctx.RootContext) error
	BeginWithTimeout(timeout int32, ctx *ctx.RootContext) error
	BeginWithTimeoutAndName(timeout int32, name string, ctx *ctx.RootContext) error
	Commit(ctx *ctx.RootContext) error
	Rollback(ctx *ctx.RootContext) error
	Suspend(unbindXid bool, ctx *ctx.RootContext) (*SuspendedResourcesHolder, error)
	Resume(suspendedResourcesHolder *SuspendedResourcesHolder, ctx *ctx.RootContext) error
	GetStatus(ctx *ctx.RootContext) (api.GlobalSession_GlobalStatus, error)
	GetXid(ctx *ctx.RootContext) string
	GlobalReport(globalStatus api.GlobalSession_GlobalStatus, ctx *ctx.RootContext) error
	GetLocalStatus() api.GlobalSession_GlobalStatus
}

type GlobalTransactionProxyService interface {
	GetProxyService() interface{}
	GetMethodTransactionInfo(methodName string) *model.TransactionInfo
}

type GlobalTransactionRole byte

type SuspendedResourcesHolder struct {
	Xid string
}