dtmcli

package
v0.0.0-...-431ae09 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 11, 2023 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// StatusPrepared status for global/branch trans status.
	// first step, tx preparation period
	StatusPrepared = "prepared"
	// StatusSubmitted status for global trans status.
	StatusSubmitted = "submitted"
	// StatusSucceed status for global/branch trans status.
	StatusSucceed = "succeed"
	// StatusFailed status for global/branch trans status.
	// NOTE: change global status to failed can stop trigger (Not recommended in production env)
	StatusFailed = "failed"
	// StatusAborting status for global trans status.
	StatusAborting = "aborting"

	// ResultSuccess for result of a trans/trans branch
	ResultSuccess = dtmimp.ResultSuccess
	// ResultFailure for result of a trans/trans branch
	ResultFailure = dtmimp.ResultFailure
	// ResultOngoing for result of a trans/trans branch
	ResultOngoing = dtmimp.ResultOngoing

	// DBTypeMysql const for driver mysql
	DBTypeMysql = dtmimp.DBTypeMysql
	// DBTypePostgres const for driver postgres
	DBTypePostgres = dtmimp.DBTypePostgres
)

Variables

View Source 
var ErrDuplicated = dtmimp.ErrDuplicated

ErrDuplicated error of DUPLICATED for only msg if QueryPrepared executed before call. then DoAndSubmit return this error

View Source 
var ErrFailure = dtmimp.ErrFailure

ErrFailure error for returned failure

View Source 
var ErrOngoing = dtmimp.ErrOngoing

ErrOngoing error for returned ongoing

View Source 
var MapFailure = dtmimp.MapFailure

MapFailure HTTP result of FAILURE

View Source 
var MapSuccess = dtmimp.MapSuccess

MapSuccess HTTP result of SUCCESS

Functions

func ErrorMessage2Error 

func ErrorMessage2Error(errMsg string, err error) error

ErrorMessage2Error return an error fmt.Errorf("%s %w", errMsg, err) but trim out duplicate wrap eg. ErrorMessage2Error("an error. FAILURE", ErrFailure) return an error with message: "an error. FAILURE", no additional " FAILURE" added

func GetCurrentDBType 

func GetCurrentDBType() string

GetCurrentDBType get currentDBType

func GetRestyClient 

func GetRestyClient() *resty.Client

GetRestyClient get the resty.Client for http request

func GetRestyClient2 

func GetRestyClient2(timeout time.Duration) *resty.Client

GetRestyClient2 get the resty.Client with the specified timeout set

func HTTPResp2DtmError 

func HTTPResp2DtmError(resp *resty.Response) error

HTTPResp2DtmError translate a resty response to error compatible with version < v1.10

func MustGenGid 

func MustGenGid(server string) string

MustGenGid generate a new gid

func Result2HttpJSON 

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

Result2HttpJSON return the http code and json result if result is error, the return proper code, else return StatusOK

func SetBarrierTableName 

func SetBarrierTableName(tablename string)

SetBarrierTableName sets barrier table name

func SetCurrentDBType 

func SetCurrentDBType(dbType string)

SetCurrentDBType set currentDBType

func TccGlobalTransaction 

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

TccGlobalTransaction begin a tcc global transaction dtm dtm server address gid global transaction ID tccFunc define the detail tcc busi

func TccGlobalTransaction2 

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

TccGlobalTransaction2 new version of TccGlobalTransaction, add custom param

func XaGlobalTransaction 

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

XaGlobalTransaction start a xa global transaction

func XaGlobalTransaction2 

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

XaGlobalTransaction2 start a xa global transaction with xa custom function

func XaLocalTransaction 

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

XaLocalTransaction start a xa local transaction

Types

type BarrierBusiFunc 

type BarrierBusiFunc func(tx *sql.Tx) error

BarrierBusiFunc type for busi func

type BranchBarrier 

type BranchBarrier struct {
	TransType        string
	Gid              string
	BranchID         string
	Op               string
	BarrierID        int
	DBType           string // DBTypeMysql | DBTypePostgres
	BarrierTableName string
}

BranchBarrier every branch info

func BarrierFrom 

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

BarrierFrom construct transaction info from request

func BarrierFromQuery 

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

BarrierFromQuery construct transaction info from request

func (*BranchBarrier) Call 

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

Call see detail description in https://en.dtm.pub/practice/barrier.html tx: local transaction connection busiCall: busi func

func (*BranchBarrier) CallWithDB 

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

CallWithDB the same as Call, but with *sql.DB

func (*BranchBarrier) MongoCall 

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

MongoCall sub-trans barrier for mongo. see http://dtm.pub/practice/barrier experimental

func (*BranchBarrier) MongoQueryPrepared 

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

MongoQueryPrepared query prepared for redis experimental

func (*BranchBarrier) QueryPrepared 

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

QueryPrepared queries prepared data

func (*BranchBarrier) RedisCheckAdjustAmount 

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

RedisCheckAdjustAmount check the value of key is valid and >= amount. then adjust the amount

func (*BranchBarrier) RedisQueryPrepared 

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

RedisQueryPrepared query prepared for redis

func (*BranchBarrier) String 

func (bb *BranchBarrier) String() string

type DB 

type DB = dtmimp.DB

DB interface

type DBConf 

type DBConf = dtmimp.DBConf

DBConf declares db configuration

type Msg 

type Msg struct {
	dtmimp.TransBase
	// contains filtered or unexported fields
}

Msg reliable msg type

func NewMsg 

func NewMsg(server string, gid string) *Msg

NewMsg create new msg

func (*Msg) Add 

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

Add add a new step

func (*Msg) AddTopic 

func (s *Msg) AddTopic(topic string, postData interface{}) *Msg

AddTopic add a new topic step

func (*Msg) BuildCustomOptions 

func (s *Msg) BuildCustomOptions()

BuildCustomOptions add custom options to the request context

func (*Msg) DoAndSubmit 

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

DoAndSubmit one method for the entire prepare->busi->submit the error returned by busiCall will be returned if busiCall return ErrFailure, then abort is called directly if busiCall return not nil error other than ErrFailure, then DoAndSubmit will call queryPrepared to get the result

func (*Msg) DoAndSubmitDB 

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

DoAndSubmitDB short method for Do on db type. please see DoAndSubmit

func (*Msg) Prepare 

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

Prepare prepare the msg, msg will later be submitted

func (*Msg) SetDelay 

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

SetDelay delay call branch, unit second

func (*Msg) Submit 

func (s *Msg) Submit() error

Submit submit the msg

type Saga 

type Saga struct {
	dtmimp.TransBase
	// contains filtered or unexported fields
}

Saga struct of saga

func NewSaga 

func NewSaga(server string, gid string) *Saga

NewSaga create a saga

func (*Saga) Add 

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

Add add a saga step

func (*Saga) AddBranchOrder 

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

AddBranchOrder specify that branch should be after preBranches. branch should is larger than all the element in preBranches

func (*Saga) BuildCustomOptions 

func (s *Saga) BuildCustomOptions()

BuildCustomOptions add custom options to the request context

func (*Saga) SetConcurrent 

func (s *Saga) SetConcurrent() *Saga

SetConcurrent enable the concurrent exec of sub trans

func (*Saga) Submit 

func (s *Saga) Submit() error

Submit submit the saga trans

type Tcc 

type Tcc struct {
	dtmimp.TransBase
}

Tcc struct of tcc

func TccFromQuery 

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

TccFromQuery tcc from request info

func (*Tcc) CallBranch 

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

CallBranch call a tcc branch

type TccGlobalFunc 

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

TccGlobalFunc type of global tcc call

type TransOptions 

type TransOptions = dtmimp.TransOptions

TransOptions transaction option

type Xa 

type Xa struct {
	dtmimp.TransBase
	Phase2URL string
}

Xa xa transaction

func XaFromQuery 

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

XaFromQuery construct xa info from request

func (*Xa) CallBranch 

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

CallBranch call a xa branch

type XaGlobalFunc 

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

XaGlobalFunc type of xa global function

type XaLocalFunc 

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

XaLocalFunc type of xa local function

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.