model

Documentation

Index

• type GlobalTransaction
  • func (gt *GlobalTransaction) Add(branchSession *apis.BranchSession)
  • func (gt *GlobalTransaction) Begin()
  • func (gt *GlobalTransaction) CanBeCommittedAsync() bool
  • func (gt *GlobalTransaction) GetBranch(branchID int64) *apis.BranchSession
  • func (gt *GlobalTransaction) HasBranch() bool
  • func (gt *GlobalTransaction) IsRollingBackDead() bool
  • func (gt *GlobalTransaction) IsSaga() bool
  • func (gt *GlobalTransaction) IsTimeout() bool
  • func (gt *GlobalTransaction) IsTimeoutGlobalStatus() bool
  • func (gt *GlobalTransaction) Remove(branchSession *apis.BranchSession)

Types

type GlobalTransaction

type GlobalTransaction struct {
	*apis.GlobalSession

	BranchSessions map[*apis.BranchSession]bool
}

func (*GlobalTransaction) Add

func (gt *GlobalTransaction) Add(branchSession *apis.BranchSession)

func (*GlobalTransaction) Begin

func (gt *GlobalTransaction) Begin()

func (*GlobalTransaction) CanBeCommittedAsync

func (gt *GlobalTransaction) CanBeCommittedAsync() bool

func (*GlobalTransaction) GetBranch

func (gt *GlobalTransaction) GetBranch(branchID int64) *apis.BranchSession

func (*GlobalTransaction) HasBranch

func (gt *GlobalTransaction) HasBranch() bool

func (*GlobalTransaction) IsRollingBackDead

func (gt *GlobalTransaction) IsRollingBackDead() bool

func (*GlobalTransaction) IsSaga

func (gt *GlobalTransaction) IsSaga() bool

func (*GlobalTransaction) IsTimeout

func (gt *GlobalTransaction) IsTimeout() bool

func (*GlobalTransaction) IsTimeoutGlobalStatus

func (gt *GlobalTransaction) IsTimeoutGlobalStatus() bool

func (*GlobalTransaction) Remove

func (gt *GlobalTransaction) Remove(branchSession *apis.BranchSession)