rename AddStepOrder to AddBranchOrder

dtmcli/saga.go

@@ -32,10 +32,10 @@ func (s *Saga) Add(action string, compensate string, postData interface{}) *Saga
 	return s
 }
 
-// AddStepOrder specify that step should be after preSteps. Step is larger than all the element in preSteps
+// AddBranchOrder specify that branch should be after preBranches. branch should is larger than all the element in preBranches
-func (s *Saga) AddStepOrder(step int, preSteps []int) *Saga {
+func (s *Saga) AddBranchOrder(branch int, preBranches []int) *Saga {
-	PanicIf(step > len(s.Steps), fmt.Errorf("step value: %d is invalid. which cannot be larger than total steps: %d", step, len(s.Steps)))
+	PanicIf(branch > len(s.Steps), fmt.Errorf("step value: %d is invalid. which cannot be larger than total steps: %d", branch, len(s.Steps)))
-	s.orders[step] = preSteps
+	s.orders[branch] = preBranches
 	return s
 }
 

examples/http_saga.go

@@ -38,8 +38,8 @@ func init() {
 			Add(Busi+"/TransIn", Busi+"/TransInRevert", req).
 			Add(Busi+"/TransIn", Busi+"/TransInRevert", req).
 			EnableConcurrent().
-			AddStepOrder(2, []int{0, 1}).
+			AddBranchOrder(2, []int{0, 1}).
-			AddStepOrder(3, []int{0, 1})
+			AddBranchOrder(3, []int{0, 1})
 		dtmcli.Logf("concurrent saga busi trans submit")
 		err := csaga.Submit()
 		dtmcli.Logf("result gid is: %s", csaga.Gid)

test/saga_concurrent_test.go

@@ -49,7 +49,7 @@ func csagaRollback(t *testing.T) {
 
 func csagaRollback2(t *testing.T) {
 	csaga := genCSaga("gid-rollback-csaga2", true, false)
-	csaga.AddStepOrder(1, []int{0})
+	csaga.AddBranchOrder(1, []int{0})
 	err := csaga.Submit()
 	assert.Nil(t, err)
 	waitTransProcessed(csaga.Gid)