holder

Documentation

Index

• type SessionHolder
  • func NewSessionHolder(manager storage.SessionManager) *SessionHolder
  • func (holder *SessionHolder) AddBranchSession(globalSession *apis.GlobalSession, session *apis.BranchSession) error
  • func (holder *SessionHolder) AddGlobalSession(session *apis.GlobalSession) error
  • func (holder *SessionHolder) AllSessions() []*apis.GlobalSession
  • func (holder *SessionHolder) FindAsyncCommittingGlobalTransactions(addressingIdentities []string) []*model.GlobalTransaction
  • func (holder *SessionHolder) FindBranchSession(xid string) []*apis.BranchSession
  • func (holder *SessionHolder) FindGlobalSession(xid string) *apis.GlobalSession
  • func (holder *SessionHolder) FindGlobalSessions(statuses []apis.GlobalSession_GlobalStatus) []*apis.GlobalSession
  • func (holder *SessionHolder) FindGlobalTransaction(xid string) *model.GlobalTransaction
  • func (holder *SessionHolder) FindRetryCommittingGlobalTransactions(addressingIdentities []string) []*model.GlobalTransaction
  • func (holder *SessionHolder) FindRetryRollbackGlobalTransactions(addressingIdentities []string) []*model.GlobalTransaction
  • func (holder *SessionHolder) InactiveGlobalSession(session *apis.GlobalSession) error
  • func (holder *SessionHolder) RemoveBranchSession(globalSession *apis.GlobalSession, session *apis.BranchSession) error
  • func (holder *SessionHolder) RemoveGlobalSession(session *apis.GlobalSession) error
  • func (holder *SessionHolder) RemoveGlobalTransaction(globalTransaction *model.GlobalTransaction) error
  • func (holder *SessionHolder) UpdateBranchSessionStatus(session *apis.BranchSession, status apis.BranchSession_BranchStatus) error
  • func (holder *SessionHolder) UpdateGlobalSessionStatus(session *apis.GlobalSession, status apis.GlobalSession_GlobalStatus) error

Types

type SessionHolder

type SessionHolder struct {
	// contains filtered or unexported fields
}

func NewSessionHolder

func NewSessionHolder(manager storage.SessionManager) *SessionHolder

func (*SessionHolder) AddBranchSession

func (holder *SessionHolder) AddBranchSession(globalSession *apis.GlobalSession, session *apis.BranchSession) error

func (*SessionHolder) AddGlobalSession

func (holder *SessionHolder) AddGlobalSession(session *apis.GlobalSession) error

func (*SessionHolder) AllSessions

func (holder *SessionHolder) AllSessions() []*apis.GlobalSession

func (*SessionHolder) FindAsyncCommittingGlobalTransactions

func (holder *SessionHolder) FindAsyncCommittingGlobalTransactions(addressingIdentities []string) []*model.GlobalTransaction

func (*SessionHolder) FindBranchSession

func (holder *SessionHolder) FindBranchSession(xid string) []*apis.BranchSession

func (*SessionHolder) FindGlobalSession

func (holder *SessionHolder) FindGlobalSession(xid string) *apis.GlobalSession

func (*SessionHolder) FindGlobalSessions

func (holder *SessionHolder) FindGlobalSessions(statuses []apis.GlobalSession_GlobalStatus) []*apis.GlobalSession

func (*SessionHolder) FindGlobalTransaction

func (holder *SessionHolder) FindGlobalTransaction(xid string) *model.GlobalTransaction

func (*SessionHolder) FindRetryCommittingGlobalTransactions

func (holder *SessionHolder) FindRetryCommittingGlobalTransactions(addressingIdentities []string) []*model.GlobalTransaction

func (*SessionHolder) FindRetryRollbackGlobalTransactions

func (holder *SessionHolder) FindRetryRollbackGlobalTransactions(addressingIdentities []string) []*model.GlobalTransaction

func (*SessionHolder) InactiveGlobalSession

func (holder *SessionHolder) InactiveGlobalSession(session *apis.GlobalSession) error

func (*SessionHolder) RemoveBranchSession

func (holder *SessionHolder) RemoveBranchSession(globalSession *apis.GlobalSession, session *apis.BranchSession) error

func (*SessionHolder) RemoveGlobalSession

func (holder *SessionHolder) RemoveGlobalSession(session *apis.GlobalSession) error

func (*SessionHolder) RemoveGlobalTransaction

func (holder *SessionHolder) RemoveGlobalTransaction(globalTransaction *model.GlobalTransaction) error

func (*SessionHolder) UpdateBranchSessionStatus

func (holder *SessionHolder) UpdateBranchSessionStatus(session *apis.BranchSession, status apis.BranchSession_BranchStatus) error

func (*SessionHolder) UpdateGlobalSessionStatus

func (holder *SessionHolder) UpdateGlobalSessionStatus(session *apis.GlobalSession, status apis.GlobalSession_GlobalStatus) error