flypiggyyoyoyo commented on code in PR #838:
URL:
https://github.com/apache/incubator-seata-go/pull/838#discussion_r2144454105
##########
pkg/saga/statemachine/engine/core/status_decision.go:
##########
@@ -22,33 +22,23 @@ import (
"errors"
"github.com/seata/seata-go/pkg/saga/statemachine/constant"
"github.com/seata/seata-go/pkg/saga/statemachine/engine/exception"
+ "github.com/seata/seata-go/pkg/saga/statemachine/engine/pcext"
+ "github.com/seata/seata-go/pkg/saga/statemachine/process_ctrl"
"github.com/seata/seata-go/pkg/saga/statemachine/statelang"
"github.com/seata/seata-go/pkg/util/log"
)
-type StatusDecisionStrategy interface {
- // DecideOnEndState Determine state machine execution status when
executing to EndState
- DecideOnEndState(ctx context.Context, processContext ProcessContext,
- stateMachineInstance statelang.StateMachineInstance, exp error)
error
- // DecideOnTaskStateFail Determine state machine execution status when
executing TaskState error
- DecideOnTaskStateFail(ctx context.Context, processContext
ProcessContext,
- stateMachineInstance statelang.StateMachineInstance, exp error)
error
- // DecideMachineForwardExecutionStatus Determine the forward execution
state of the state machine
- DecideMachineForwardExecutionStatus(ctx context.Context,
- stateMachineInstance statelang.StateMachineInstance, exp error,
specialPolicy bool) error
-}
-
type DefaultStatusDecisionStrategy struct {
}
func NewDefaultStatusDecisionStrategy() *DefaultStatusDecisionStrategy {
Review Comment:
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
