Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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
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

holder

package

Go to main page

Versions in this module

v0

v0.1.1

Jul 17, 2020

v0.1.0

Jul 9, 2020

v0.1.0-fix

Jul 10, 2020

v0.0.9

Jul 9, 2020

v0.0.8

Jul 9, 2020

v0.0.6

Jul 9, 2020

v0.0.5

Jul 8, 2020

v0.0.4

Jul 8, 2020

v0.0.3

Jul 8, 2020

v0.0.3-fix

Jul 8, 2020

v0.0.2

Jul 6, 2020

v0.0.1

Jul 2, 2020

Changes in this version

+ const DeleteBranchTransactionDO

+ const DeleteGlobalTransactionDO

+ const InsertBranchTransactionDO

+ const InsertGlobalTransactionDO

+ const QueryBranchTransactionDOByXid

+ const QueryGlobalTransactionDOByTransactionId

+ const QueryGlobalTransactionDOByXid

+ const QueryMaxBranchId

+ const QueryMaxTransactionId

+ const UpdateBranchTransactionDO

+ const UpdateGlobalTransactionDO

+ var ASYNC_COMMITTING_SESSION_MANAGER_NAME = "async.commit.data"

+ var FileTrxNum int64 = 0

+ var HisDataFilenamePostfix = ".1"

+ var MaxTrxTimeoutMills int64 = 30 * 60 * 1000

+ var PerFileBlockSize int64 = 65535 * 8

+ var RETRY_COMMITTING_SESSION_MANAGER_NAME = "retry.commit.data"

+ var RETRY_ROLLBACKING_SESSION_MANAGER_NAME = "retry.rollback.data"

+ func Init()

+ type AbstractSessionManager struct

+ Name string

+ TransactionStoreManager TransactionStoreManager

+ func (sessionManager *AbstractSessionManager) AddBranchSession(globalSession *session.GlobalSession, session *session.BranchSession) error

+ func (sessionManager *AbstractSessionManager) AddGlobalSession(session *session.GlobalSession) error

+ func (sessionManager *AbstractSessionManager) RemoveBranchSession(globalSession *session.GlobalSession, session *session.BranchSession) error

+ func (sessionManager *AbstractSessionManager) RemoveGlobalSession(session *session.GlobalSession) error

+ func (sessionManager *AbstractSessionManager) UpdateBranchSessionStatus(session *session.BranchSession, status meta.BranchStatus) error

+ func (sessionManager *AbstractSessionManager) UpdateGlobalSessionStatus(session *session.GlobalSession, status meta.GlobalStatus) error

+ type AbstractTransactionStoreManager struct

+ func (transactionStoreManager *AbstractTransactionStoreManager) GetCurrentMaxSessionId() int64

+ func (transactionStoreManager *AbstractTransactionStoreManager) ReadSession(xid string) *session.GlobalSession

+ func (transactionStoreManager *AbstractTransactionStoreManager) ReadSessionWithBranchSessions(xid string, withBranchSessions bool) *session.GlobalSession

+ func (transactionStoreManager *AbstractTransactionStoreManager) ReadSessionWithSessionCondition(sessionCondition model.SessionCondition) []*session.GlobalSession

+ func (transactionStoreManager *AbstractTransactionStoreManager) Shutdown()

+ func (transactionStoreManager *AbstractTransactionStoreManager) WriteSession(logOperation LogOperation, session session.SessionStorable) bool

+ type DBTransactionStoreManager struct

+ LogStore ILogStore

+ func (storeManager *DBTransactionStoreManager) GetCurrentMaxSessionId() int64

+ func (storeManager *DBTransactionStoreManager) ReadSession(xid string) *session.GlobalSession

+ func (storeManager *DBTransactionStoreManager) ReadSessionByTransactionId(transactionId int64) *session.GlobalSession

+ func (storeManager *DBTransactionStoreManager) ReadSessionWithBranchSessions(xid string, withBranchSessions bool) *session.GlobalSession

+ func (storeManager *DBTransactionStoreManager) ReadSessionWithSessionCondition(sessionCondition model.SessionCondition) []*session.GlobalSession

+ func (storeManager *DBTransactionStoreManager) Shutdown()

+ func (storeManager *DBTransactionStoreManager) WriteSession(logOperation LogOperation, session session.SessionStorable) bool

+ type DataBaseSessionManager struct

+ TaskName string

+ TransactionStoreManager TransactionStoreManager

+ func (sessionManager *DataBaseSessionManager) AddBranchSession(globalSession *session.GlobalSession, session *session.BranchSession) error

+ func (sessionManager *DataBaseSessionManager) AddGlobalSession(session *session.GlobalSession) error

+ func (sessionManager *DataBaseSessionManager) AllSessions() []*session.GlobalSession

+ func (sessionManager *DataBaseSessionManager) FindGlobalSession(xid string) *session.GlobalSession

+ func (sessionManager *DataBaseSessionManager) FindGlobalSessionWithBranchSessions(xid string, withBranchSessions bool) *session.GlobalSession

+ func (sessionManager *DataBaseSessionManager) FindGlobalSessions(condition model.SessionCondition) []*session.GlobalSession

+ func (sessionManager *DataBaseSessionManager) Reload()

+ func (sessionManager *DataBaseSessionManager) RemoveBranchSession(globalSession *session.GlobalSession, session *session.BranchSession) error

+ func (sessionManager *DataBaseSessionManager) RemoveGlobalSession(session *session.GlobalSession) error

+ func (sessionManager *DataBaseSessionManager) UpdateBranchSessionStatus(session *session.BranchSession, status meta.BranchStatus) error

+ func (sessionManager *DataBaseSessionManager) UpdateGlobalSessionStatus(session *session.GlobalSession, status meta.GlobalStatus) error

+ type DefaultSessionManager struct

+ SessionMap map[string]*session.GlobalSession

+ func (sessionManager *DefaultSessionManager) AddGlobalSession(session *session.GlobalSession) error

+ func (sessionManager *DefaultSessionManager) AllSessions() []*session.GlobalSession

+ func (sessionManager *DefaultSessionManager) FindGlobalSession(xid string) *session.GlobalSession

+ func (sessionManager *DefaultSessionManager) FindGlobalSessionWithBranchSessions(xid string, withBranchSessions bool) *session.GlobalSession

+ func (sessionManager *DefaultSessionManager) FindGlobalSessions(condition model.SessionCondition) []*session.GlobalSession

+ func (sessionManager *DefaultSessionManager) RemoveGlobalSession(session *session.GlobalSession) error

+ func (sessionManager *DefaultSessionManager) SetTransactionStoreManager(transactionStoreManager TransactionStoreManager)

+ type FileBasedSessionManager struct

+ func (sessionManager *FileBasedSessionManager) Reload()

+ type FileTransactionStoreManager struct

+ LastModifiedTime int64

+ SessionManager SessionManager

+ TrxStartTimeMills int64

+ func (storeManager *FileTransactionStoreManager) GetCurrentMaxSessionId() int64

+ func (storeManager *FileTransactionStoreManager) HasRemaining(isHistory bool) bool

+ func (storeManager *FileTransactionStoreManager) InitFile(fullFileName string)

+ func (storeManager *FileTransactionStoreManager) ReadSession(xid string) *session.GlobalSession

+ func (storeManager *FileTransactionStoreManager) ReadSessionWithBranchSessions(xid string, withBranchSessions bool) *session.GlobalSession

+ func (storeManager *FileTransactionStoreManager) ReadSessionWithSessionCondition(sessionCondition model.SessionCondition) []*session.GlobalSession

+ func (storeManager *FileTransactionStoreManager) ReadWriteStore(readSize int, isHistory bool) []*TransactionWriteStore

+ func (storeManager *FileTransactionStoreManager) Shutdown()

+ func (storeManager *FileTransactionStoreManager) WriteSession(logOperation LogOperation, session session.SessionStorable) bool

+ type ILogStore interface

+ DeleteBranchTransactionDO func(branchTransaction model.BranchTransactionDO) bool

+ DeleteGlobalTransactionDO func(globalTransaction model.GlobalTransactionDO) bool

+ GetCurrentMaxSessionId func(high int64, low int64) int64

+ InsertBranchTransactionDO func(branchTransaction model.BranchTransactionDO) bool

+ InsertGlobalTransactionDO func(globalTransaction model.GlobalTransactionDO) bool

+ QueryBranchTransactionDOByXid func(xid string) []*model.BranchTransactionDO

+ QueryBranchTransactionDOByXids func(xids []string) []*model.BranchTransactionDO

+ QueryGlobalTransactionDOByStatuses func(statuses []int, limit int) []*model.GlobalTransactionDO

+ QueryGlobalTransactionDOByTransactionId func(transactionId int64) *model.GlobalTransactionDO

+ QueryGlobalTransactionDOByXid func(xid string) *model.GlobalTransactionDO

+ UpdateBranchTransactionDO func(branchTransaction model.BranchTransactionDO) bool

+ UpdateGlobalTransactionDO func(globalTransaction model.GlobalTransactionDO) bool

+ type LogOperation byte

+ const LogOperationBranchAdd

+ const LogOperationBranchRemove

+ const LogOperationBranchUpdate

+ const LogOperationGlobalAdd

+ const LogOperationGlobalRemove

+ const LogOperationGlobalUpdate

+ func (t LogOperation) String() string

+ type LogStoreDataBaseDAO struct

+ func (dao *LogStoreDataBaseDAO) DeleteBranchTransactionDO(branchTransaction model.BranchTransactionDO) bool

+ func (dao *LogStoreDataBaseDAO) DeleteGlobalTransactionDO(globalTransaction model.GlobalTransactionDO) bool

+ func (dao *LogStoreDataBaseDAO) GetCurrentMaxSessionId(high int64, low int64) int64

+ func (dao *LogStoreDataBaseDAO) InsertBranchTransactionDO(branchTransaction model.BranchTransactionDO) bool

+ func (dao *LogStoreDataBaseDAO) InsertGlobalTransactionDO(globalTransaction model.GlobalTransactionDO) bool

+ func (dao *LogStoreDataBaseDAO) QueryBranchTransactionDOByXid(xid string) []*model.BranchTransactionDO

+ func (dao *LogStoreDataBaseDAO) QueryBranchTransactionDOByXids(xids []string) []*model.BranchTransactionDO

+ func (dao *LogStoreDataBaseDAO) QueryGlobalTransactionDOByStatuses(statuses []int, limit int) []*model.GlobalTransactionDO

+ func (dao *LogStoreDataBaseDAO) QueryGlobalTransactionDOByTransactionId(transactionId int64) *model.GlobalTransactionDO

+ func (dao *LogStoreDataBaseDAO) QueryGlobalTransactionDOByXid(xid string) *model.GlobalTransactionDO

+ func (dao *LogStoreDataBaseDAO) UpdateBranchTransactionDO(branchTransaction model.BranchTransactionDO) bool

+ func (dao *LogStoreDataBaseDAO) UpdateGlobalTransactionDO(globalTransaction model.GlobalTransactionDO) bool

+ type Reloadable interface

+ Reload func()

+ type ReloadableStore interface

+ HasRemaining func(isHistory bool) bool

+ ReadWriteStore func(readSize int, isHistory bool) []*TransactionWriteStore

+ type SessionHolder struct

+ AsyncCommittingSessionManager SessionManager

+ RetryCommittingSessionManager SessionManager

+ RetryRollbackingSessionManager SessionManager

+ RootSessionManager SessionManager

+ func GetSessionHolder() SessionHolder

+ func (sessionHolder SessionHolder) FindGlobalSession(xid string) *session.GlobalSession

+ func (sessionHolder SessionHolder) FindGlobalSessionWithBranchSessions(xid string, withBranchSessions bool) *session.GlobalSession

+ type SessionManager interface

+ AddBranchSession func(globalSession *session.GlobalSession, session *session.BranchSession) error

+ AddGlobalSession func(session *session.GlobalSession) error

+ AllSessions func() []*session.GlobalSession

+ FindGlobalSession func(xid string) *session.GlobalSession

+ FindGlobalSessionWithBranchSessions func(xid string, withBranchSessions bool) *session.GlobalSession

+ FindGlobalSessions func(condition model.SessionCondition) []*session.GlobalSession

+ RemoveBranchSession func(globalSession *session.GlobalSession, session *session.BranchSession) error

+ RemoveGlobalSession func(session *session.GlobalSession) error

+ UpdateBranchSessionStatus func(session *session.BranchSession, status meta.BranchStatus) error

+ UpdateGlobalSessionStatus func(session *session.GlobalSession, status meta.GlobalStatus) error

+ func NewDataBaseSessionManager(taskName string, conf config.DBStoreConfig) SessionManager

+ func NewDefaultSessionManager(name string) SessionManager

+ func NewFileBasedSessionManager(conf config.FileStoreConfig) SessionManager

+ type TransactionStoreManager interface

+ GetCurrentMaxSessionId func() int64

+ ReadSession func(xid string) *session.GlobalSession

+ ReadSessionWithBranchSessions func(xid string, withBranchSessions bool) *session.GlobalSession

+ ReadSessionWithSessionCondition func(sessionCondition model.SessionCondition) []*session.GlobalSession

+ Shutdown func()

+ WriteSession func(logOperation LogOperation, session session.SessionStorable) bool

+ type TransactionWriteStore struct

+ LogOperation LogOperation

+ SessionRequest session.SessionStorable

+ func (transactionWriteStore *TransactionWriteStore) Decode(src []byte)

+ func (transactionWriteStore *TransactionWriteStore) Encode() ([]byte, error)