feature: saga support loop execution on state (#3468) (8a4b6a37) · Commits · Summer2021 / 211010717

Unverified Commit 8a4b6a37 authored 4 years ago by

Yaoyu Li Committed by GitHub 4 years ago

Browse files

feature: saga support loop execution on state (#3468)

parent aa17303f

No related branches found

No related tags found

Hide whitespace changes

Inline Side-by-side

Showing

changes/1.5.0.md 1 addition, 0 deletions

changes/1.5.0.md
changes/en-us/1.5.0.md 1 addition, 0 deletions

changes/en-us/1.5.0.md
saga/seata-saga-engine-store/src/main/java/io/seata/saga/engine/store/db/DbAndReportTcStateLogStore.java 8 additions, 3 deletions

...eata/saga/engine/store/db/DbAndReportTcStateLogStore.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/impl/ProcessCtrlStateMachineEngine.java 24 additions, 3 deletions

...seata/saga/engine/impl/ProcessCtrlStateMachineEngine.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/StateMachineProcessHandler.java 2 additions, 0 deletions

...o/seata/saga/engine/pcext/StateMachineProcessHandler.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/StateMachineProcessRouter.java 1 addition, 0 deletions

...io/seata/saga/engine/pcext/StateMachineProcessRouter.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/handlers/LoopStartStateHandler.java 165 additions, 0 deletions

...ata/saga/engine/pcext/handlers/LoopStartStateHandler.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/handlers/SubStateMachineHandler.java 1 addition, 1 deletion

...ta/saga/engine/pcext/handlers/SubStateMachineHandler.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/interceptors/LoopTaskHandlerInterceptor.java 138 additions, 0 deletions

...engine/pcext/interceptors/LoopTaskHandlerInterceptor.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/interceptors/ServiceTaskHandlerInterceptor.java 13 additions, 5 deletions

...ine/pcext/interceptors/ServiceTaskHandlerInterceptor.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/routers/TaskStateRouter.java 13 additions, 1 deletion

...a/io/seata/saga/engine/pcext/routers/TaskStateRouter.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/utils/CompensationHolder.java 1 addition, 1 deletion

.../io/seata/saga/engine/pcext/utils/CompensationHolder.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/utils/EngineUtils.java 33 additions, 2 deletions

...in/java/io/seata/saga/engine/pcext/utils/EngineUtils.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/utils/LoopContextHolder.java 105 additions, 0 deletions

...a/io/seata/saga/engine/pcext/utils/LoopContextHolder.java
saga/seata-saga-engine/src/main/java/io/seata/saga/engine/pcext/utils/LoopTaskUtils.java 429 additions, 0 deletions

.../java/io/seata/saga/engine/pcext/utils/LoopTaskUtils.java
saga/seata-saga-engine/src/main/resources/META-INF/services/io.seata.saga.engine.pcext.StateHandlerInterceptor 2 additions, 1 deletion

...rvices/io.seata.saga.engine.pcext.StateHandlerInterceptor
saga/seata-saga-statelang/src/main/java/io/seata/saga/statelang/domain/DomainConstants.java 12 additions, 0 deletions

.../java/io/seata/saga/statelang/domain/DomainConstants.java
saga/seata-saga-statelang/src/main/java/io/seata/saga/statelang/domain/LoopStartState.java 25 additions, 0 deletions

...n/java/io/seata/saga/statelang/domain/LoopStartState.java
saga/seata-saga-statelang/src/main/java/io/seata/saga/statelang/domain/TaskState.java 48 additions, 0 deletions

...c/main/java/io/seata/saga/statelang/domain/TaskState.java
saga/seata-saga-statelang/src/main/java/io/seata/saga/statelang/domain/impl/AbstractTaskState.java 64 additions, 1 deletion

...o/seata/saga/statelang/domain/impl/AbstractTaskState.java

with 1086 additions and 18 deletions

Please register or to comment