dtmsvr

Dec 18, 2021

Changes in this version

+ func GetStore() storage.Store

type TransGlobal

+ func GetTransGlobal(gid string) *TransGlobal

Nov 8, 2021

Changes in this version

type TransBranch

+ BinData []byte

+ Op string

type TransGlobal

+ BinPayloads [][]byte

+ Payloads []string

+ Steps []map[string]string

Oct 29, 2021

Changes in this version

+ var NowForwardDuration time.Duration = time.Duration(0)

type TransGlobal

+ CustomData string

+ Options string

Oct 7, 2021

Changes in this version

+ var CronForwardDuration time.Duration = time.Duration(0)

+ var UpdateBranchAsyncInterval = 200 * time.Millisecond

Aug 11, 2021

Changes in this version

+ func PopulateDB(skipDrop bool)

type TransGlobal

+ Protocol string

+ func TransFromDtmRequest(c *dtmgrpc.DtmRequest) *TransGlobal

Jul 29, 2021

Changes in this version

+ var TransProcessedTestChan chan string = nil

+ func CronExpiredTrans(num int)

+ func CronTransOnce(expireIn time.Duration) bool

+ func GenGid() string

+ func MainStart()

+ func PopulateMysql(skipDrop bool)

+ func StartSvr()

+ func WaitTransProcessed(gid string)

+ type M = map[string]interface

+ type TransBranch struct

+ BranchID string

+ BranchType string

+ Data string

+ FinishTime *time.Time

+ Gid string

+ RollbackTime *time.Time

+ Status string

+ URL string

+ func (*TransBranch) TableName() string

+ type TransGlobal struct

+ CommitTime *time.Time

+ Data string

+ FinishTime *time.Time

+ Gid string

+ NextCronInterval int64

+ NextCronTime *time.Time

+ QueryPrepared string

+ RollbackTime *time.Time

+ Status string

+ TransType string

+ func TransFromContext(c *gin.Context) *TransGlobal

+ func TransFromDb(db *common.DB, gid string) *TransGlobal

+ func (*TransGlobal) TableName() string

+ func (t *TransGlobal) Process(db *common.DB)