dtmcli

Jul 8, 2022

Changes in this version

+ func IsOngoing(resp *resty.Response, err error) bool

+ func IsRollback(resp *resty.Response, err error) bool

Jun 10, 2022

Changes in this version

type BranchBarrier

+ BarrierTableName string

+ DBType string

May 4, 2022

Changes in this version

+ func Result2HttpJSON(result interface{}) (code int, res interface{})

Apr 29, 2022

Changes in this version

+ func Result2HttpCode(result interface{}) int

Mar 25, 2022

Changes in this version

+ func XaGlobalTransaction(server string, gid string, xaFunc XaGlobalFunc) error

+ func XaGlobalTransaction2(server string, gid string, custom func(*Xa), xaFunc XaGlobalFunc) (rerr error)

+ func XaLocalTransaction(qs url.Values, dbConf DBConf, xaFunc XaLocalFunc) error

type Xa

+ Phase2URL string

Mar 22, 2022

Changes in this version

type Msg

+ func (s *Msg) BuildCustomOptions()

+ func (s *Msg) SetDelay(delay uint64) *Msg

type Saga

+ func (s *Saga) BuildCustomOptions()

+ func (s *Saga) SetConcurrent() *Saga

Feb 10, 2022

Changes in this version

+ var ErrDuplicated = dtmimp.ErrDuplicated

Feb 3, 2022

Changes in this version

type BranchBarrier

+ func (bb *BranchBarrier) MongoCall(mc *mongo.Client, busiCall func(mongo.SessionContext) error) (rerr error)

+ func (bb *BranchBarrier) MongoQueryPrepared(mc *mongo.Client) error

type Saga

+ func (s *Saga) AddConcurrentContext()

Jan 27, 2022

Changes in this version

type BranchBarrier

+ func (bb *BranchBarrier) RedisQueryPrepared(rd *redis.Client, barrierExpire int) error

type Msg

+ func (s *Msg) DoAndSubmit(queryPrepared string, busiCall func(bb *BranchBarrier) error) error

+ func (s *Msg) DoAndSubmitDB(queryPrepared string, db *sql.DB, busiCall BarrierBusiFunc) error

Jan 21, 2022

Changes in this version

type BranchBarrier

+ func (bb *BranchBarrier) RedisCheckAdjustAmount(rd *redis.Client, key string, amount int, barrierExpire int) error

Jan 10, 2022

Changes in this version

+ func String2DtmError(str string) error

Jan 8, 2022

Changes in this version

+ func GetRestyClient() *resty.Client

+ func GetXaSQLTimeoutMs() int

+ func SetXaSQLTimeoutMs(ms int)

Jan 6, 2022

Changes in this version

type BranchBarrier

+ func (bb *BranchBarrier) QueryPrepared(db *sql.DB) error

type Msg

+ func (s *Msg) PrepareAndSubmit(queryPrepared string, db *sql.DB, busiCall BarrierBusiFunc) error

Jan 1, 2022

Changes in this version

+ func TccGlobalTransaction2(dtm string, gid string, custom func(*Tcc), tccFunc TccGlobalFunc) (rerr error)

type XaClient

+ func (xc *XaClient) XaGlobalTransaction2(gid string, custom func(*Xa), xaFunc XaGlobalFunc) (rerr error)

Dec 31, 2021

Changes in this version

+ func SetPassthroughHeaders(headers []string)

Dec 31, 2021

Changes in this version

+ func OnAfterResponse(middleware func(c *resty.Client, resp *resty.Response) error)

+ func OnBeforeRequest(middleware func(c *resty.Client, r *resty.Request) error)

+ func SetBarrierTableName(tablename string)

+ func SetPassthroughHeader(headers []string)

Dec 24, 2021

Changes in this version

+ const BranchAction

+ const BranchCancel

+ const BranchCommit

+ const BranchCompensate

+ const BranchConfirm

+ const BranchRollback

+ const BranchTry

+ const DBTypeMysql

+ const DBTypePostgres

+ const ResultFailure

+ const ResultOngoing

+ const ResultSuccess

+ const StatusAborting

+ const StatusFailed

+ const StatusPrepared

+ const StatusSubmitted

+ const StatusSucceed

+ var ErrFailure = dtmimp.ErrFailure

+ var ErrOngoing = dtmimp.ErrOngoing

+ var MapFailure = dtmimp.MapFailure

+ var MapSuccess = dtmimp.MapSuccess

+ func GetCurrentDBType() string

+ func GetXaSqlTimeoutMs() int

+ func MustGenGid(server string) string

+ func SetCurrentDBType(dbType string)

+ func SetXaSqlTimeoutMs(ms int)

+ func TccGlobalTransaction(dtm string, gid string, tccFunc TccGlobalFunc) (rerr error)

+ type BarrierBusiFunc func(tx *sql.Tx) error

+ type BranchBarrier struct

+ BarrierID int

+ BranchID string

+ Gid string

+ Op string

+ TransType string

+ func BarrierFrom(transType, gid, branchID, op string) (*BranchBarrier, error)

+ func BarrierFromQuery(qs url.Values) (*BranchBarrier, error)

+ func (bb *BranchBarrier) Call(tx *sql.Tx, busiCall BarrierBusiFunc) (rerr error)

+ func (bb *BranchBarrier) CallWithDB(db *sql.DB, busiCall BarrierBusiFunc) error

+ func (bb *BranchBarrier) String() string

+ type DB = dtmimp.DB

+ type DBConf = dtmimp.DBConf

+ type Msg struct

+ func NewMsg(server string, gid string) *Msg

+ func (s *Msg) Add(action string, postData interface{}) *Msg

+ func (s *Msg) Prepare(queryPrepared string) error

+ func (s *Msg) Submit() error

+ type Saga struct

+ func NewSaga(server string, gid string) *Saga

+ func (s *Saga) Add(action string, compensate string, postData interface{}) *Saga

+ func (s *Saga) AddBranchOrder(branch int, preBranches []int) *Saga

+ func (s *Saga) EnableConcurrent() *Saga

+ func (s *Saga) Submit() error

+ type Tcc struct

+ func TccFromQuery(qs url.Values) (*Tcc, error)

+ func (t *Tcc) CallBranch(body interface{}, tryURL string, confirmURL string, cancelURL string) (*resty.Response, error)

+ type TccGlobalFunc func(tcc *Tcc) (*resty.Response, error)

+ type TransOptions = dtmimp.TransOptions

+ type Xa struct

+ func XaFromQuery(qs url.Values) (*Xa, error)

+ func (x *Xa) CallBranch(body interface{}, url string) (*resty.Response, error)

+ type XaClient struct

+ func NewXaClient(server string, mysqlConf DBConf, notifyURL string, register XaRegisterCallback) (*XaClient, error)

+ func (xc *XaClient) HandleCallback(gid string, branchID string, action string) (interface{}, error)

+ func (xc *XaClient) XaGlobalTransaction(gid string, xaFunc XaGlobalFunc) (rerr error)

+ func (xc *XaClient) XaLocalTransaction(qs url.Values, xaFunc XaLocalFunc) error

+ type XaGlobalFunc func(xa *Xa) (*resty.Response, error)

+ type XaLocalFunc func(db *sql.DB, xa *Xa) error

+ type XaRegisterCallback func(path string, xa *XaClient)