Browse Source

Merge branch 'main' of github.com:xyctruth/dtm

pull/322/head
xyctruth 4 years ago
parent
commit
1a9c0cf8ef
  1. 6
      README.md
  2. 2
      conf.sample.yml
  3. 6
      helper/README-en.md
  4. 6
      test/busi/quick_start.go

6
README.md

@ -59,11 +59,11 @@ go run main.go
req := &gin.H{"amount": 30} // micro-service payload req := &gin.H{"amount": 30} // micro-service payload
// DtmServer is the address of DTM micro-service // DtmServer is the address of DTM micro-service
saga := dtmcli.NewSaga(DtmServer, shortuuid.New()). saga := dtmcli.NewSaga(DtmServer, shortuuid.New()).
// add a TransOut subtraction,forward operation with url: qsBusi+"/TransOut", reverse compensation operation with url: qsBusi+"/TransOutCom" // add a TransOut sub-transaction,forward operation with url: qsBusi+"/TransOut", reverse compensation operation with url: qsBusi+"/TransOutCom"
Add(qsBusi+"/TransOut", qsBusi+"/TransOutCom", req). Add(qsBusi+"/TransOut", qsBusi+"/TransOutCom", req).
// add a TransIn subtraction, forward operation with url: qsBusi+"/TransIn", reverse compensation operation with url: qsBusi+"/TransInCom" // add a TransIn sub-transaction, forward operation with url: qsBusi+"/TransIn", reverse compensation operation with url: qsBusi+"/TransInCom"
Add(qsBusi+"/TransIn", qsBusi+"/TransInCom", req) Add(qsBusi+"/TransIn", qsBusi+"/TransInCom", req)
// submit the created saga transaction,dtm ensures all subtractions either complete or get revoked // submit the created saga transaction,dtm ensures all sub-transactions either complete or get revoked
err := saga.Submit() err := saga.Submit()
``` ```

2
conf.sample.yml

@ -46,7 +46,7 @@
# Driver: 'dtm-driver-http' # name of the driver to handle register/discover # Driver: 'dtm-driver-http' # name of the driver to handle register/discover
# RegistryType: 'nacos' # RegistryType: 'nacos'
# RegistryAddress: '127.0.0.1:8848,127.0.0.1:8848' # RegistryAddress: '127.0.0.1:8848,127.0.0.1:8848'
# RegistryOptions: '{"UserName":"nacos","Password":"nacos","NotLoadCacheAtStart":true}' # RegistryOptions: '{"namespaceId":"a6843d66-cf5b-43ab-b7e7-461200dfe76c","UserName":"nacos","Password":"nacos","NotLoadCacheAtStart":true}'
# Target: '{"ServiceName":"dtmService","Enable":true,"Healthy":true,"Weight":10}' # target and options # Target: '{"ServiceName":"dtmService","Enable":true,"Healthy":true,"Weight":10}' # target and options
# EndPoint: '127.0.0.1:36789' # EndPoint: '127.0.0.1:36789'

6
helper/README-en.md

@ -57,11 +57,11 @@ go run main.go
req := &gin.H{"amount": 30} // micro-service payload req := &gin.H{"amount": 30} // micro-service payload
// DtmServer is the address of DTM micro-service // DtmServer is the address of DTM micro-service
saga := dtmcli.NewSaga(DtmServer, shortuuid.New()). saga := dtmcli.NewSaga(DtmServer, shortuuid.New()).
// add a TransOut subtraction,forward operation with url: qsBusi+"/TransOut", reverse compensation operation with url: qsBusi+"/TransOutCom" // add a TransOut sub-transaction,forward operation with url: qsBusi+"/TransOut", reverse compensation operation with url: qsBusi+"/TransOutCom"
Add(qsBusi+"/TransOut", qsBusi+"/TransOutCom", req). Add(qsBusi+"/TransOut", qsBusi+"/TransOutCom", req).
// add a TransIn subtraction, forward operation with url: qsBusi+"/TransIn", reverse compensation operation with url: qsBusi+"/TransInCom" // add a TransIn sub-transaction, forward operation with url: qsBusi+"/TransIn", reverse compensation operation with url: qsBusi+"/TransInCom"
Add(qsBusi+"/TransIn", qsBusi+"/TransInCom", req) Add(qsBusi+"/TransIn", qsBusi+"/TransInCom", req)
// submit the created saga transaction,dtm ensures all subtractions either complete or get revoked // submit the created saga transaction,dtm ensures all sub-transactions either complete or get revoked
err := saga.Submit() err := saga.Submit()
``` ```

6
test/busi/quick_start.go

@ -61,11 +61,11 @@ func QsFireRequest() string {
req := &gin.H{"amount": 30} // load of micro-service req := &gin.H{"amount": 30} // load of micro-service
// DtmServer is the url of dtm // DtmServer is the url of dtm
saga := dtmcli.NewSaga(dtmServer, shortuuid.New()). saga := dtmcli.NewSaga(dtmServer, shortuuid.New()).
// add a TransOut subtraction,forward operation with url: qsBusi+"/TransOut", reverse compensation operation with url: qsBusi+"/TransOutCompensate" // add a TransOut sub-transaction,forward operation with url: qsBusi+"/TransOut", reverse compensation operation with url: qsBusi+"/TransOutCompensate"
Add(qsBusi+"/TransOut", qsBusi+"/TransOutCompensate", req). Add(qsBusi+"/TransOut", qsBusi+"/TransOutCompensate", req).
// add a TransIn subtraction, forward operation with url: qsBusi+"/TransIn", reverse compensation operation with url: qsBusi+"/TransInCompensate" // add a TransIn sub-transaction, forward operation with url: qsBusi+"/TransIn", reverse compensation operation with url: qsBusi+"/TransInCompensate"
Add(qsBusi+"/TransIn", qsBusi+"/TransInCompensate", req) Add(qsBusi+"/TransIn", qsBusi+"/TransInCompensate", req)
// submit the created saga transaction,dtm ensures all subtractions either complete or get revoked // submit the created saga transaction,dtm ensures all sub-transactions either complete or get revoked
err := saga.Submit() err := saga.Submit()
if err != nil { if err != nil {

Loading…
Cancel
Save