English | 简体中文
Minimal usage example for client/dtmcli
Refer to dtm installation and running
go run main.goThe order of execution can be seen in the log of dtmcli-qs as follows.
- TransOut
- TransIn
The entire saga transaction was executed successfully
// Business-specific microservice address
const qsBusi = "http://localhost:8081/api/busi_saga"
req := &gin.H{"amount": 30} // load of the microservice
// DtmServer is the address of the DTM service and is a url
DtmServer := "http://localhost:36789/api/dtmsvr"
saga := dtmcli.NewSaga(DtmServer, dtmcli.MustGenGid(DtmServer)).
// Add a subtransaction of TransOut, the forward action is url: qsBusi+"/TransOut" and the compensating action is url: qsBusi+"/TransOutCom"
Add(qsBusi+"/TransOut", qsBusi+"/TransOutCom", req).
// Add a subtransaction of TransIn, with url: qsBusi+"/TransIn" for the forward operation and url: qsBusi+"/TransInCom" for the compensating operation
Add(qsBusi+"/TransIn", qsBusi+"/TransInCom", req)
// commit saga transaction, dtm will complete all subtransactions/rollback all subtransactions
err := saga.Submit()