修改可见性

saga/orchestrator.go

@@ -49,7 +49,7 @@ func (orchestrator *Orchestrator) Run() (interface{}, error) {
 		}
 
 		if err != nil {
-			err = SaveOrchestratorState(orchestrator.stateStoreName, orchestrator.sagaName,
+			err = saveOrchestratorState(orchestrator.stateStoreName, orchestrator.sagaName,
 				orchestrator.name, step.RollbackContextData, index)
 			if err != nil {
 				return nil, err
@@ -75,17 +75,17 @@ func (orchestrator *Orchestrator) Rollback(startIndex int) {
 			fmt.Println("Rollback", "orchestrator.rollbackStep", err)
 		}
 
-		err = SaveOrchestratorState(orchestrator.stateStoreName, orchestrator.sagaName, orchestrator.name,
+		err = saveOrchestratorState(orchestrator.stateStoreName, orchestrator.sagaName, orchestrator.name,
 			rollbackStep.RollbackContextData, i-1)
 		if err != nil {
-			fmt.Println("Rollback", "SaveOrchestratorState", err)
+			fmt.Println("Rollback", "saveOrchestratorState", err)
 			return
 		}
 	}
 
-	err := DeleteOrchestratorState(orchestrator.stateStoreName, orchestrator.sagaName, orchestrator.name)
+	err := deleteOrchestratorState(orchestrator.stateStoreName, orchestrator.sagaName, orchestrator.name)
 	if err != nil {
-		fmt.Println("Rollback", "DeleteOrchestratorState", err)
+		fmt.Println("Rollback", "deleteOrchestratorState", err)
 		return
 	}
 }

saga/saga.go

@@ -70,5 +70,5 @@ func (s *Saga) BuildOrchestrator(orchestratorName string, rollbackRetryPeriodSec
 }
 
 func (s *Saga) GetOrchestratorNeedRollback() ([]OrchestratorState, error) {
-	return GetSagaOrchestratorStates(s.stateStoreName, s.name)
+	return getSagaOrchestratorStates(s.stateStoreName, s.name)
 }

saga/state_store.go

@@ -16,7 +16,7 @@ type OrchestratorState struct {
 	RollbackStartIndex  int
 }
 
-func DeleteOrchestratorState(stateStoreName string, sagaName string, orchestratorName string) error {
+func deleteOrchestratorState(stateStoreName string, sagaName string, orchestratorName string) error {
 	orchestratorNames, err := getSagaIndexState(stateStoreName, sagaName)
 	if err != nil {
 		return err
@@ -93,7 +93,7 @@ func getSagaIndexState(stateStoreName string, sagaName string) ([]string, error)
 	return orchestratorNames, nil
 }
 
-func SaveOrchestratorState(stateStoreName string, sagaName string, orchestratorName string,
+func saveOrchestratorState(stateStoreName string, sagaName string, orchestratorName string,
 	rollbackContextData string, rollbackStartIndex int) error {
 	orchestratorStateJsonData, err := json.Marshal(&OrchestratorState{
 		Name:                orchestratorName,
@@ -150,7 +150,7 @@ func SaveOrchestratorState(stateStoreName string, sagaName string, orchestratorN
 		})
 }
 
-func GetSagaOrchestratorStates(stateStoreName string, sagaName string) ([]OrchestratorState, error) {
+func getSagaOrchestratorStates(stateStoreName string, sagaName string) ([]OrchestratorState, error) {
 	stateItem, err := dapr_client.GetInstance().GetState(stateStoreName, sagaName, nil)
 	if err != nil {
 		return nil, err