You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/02/09 09:15:05 UTC
[incubator-inlong] branch master updated (69dec9d -> fa3ca74)
This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from 69dec9d [issue-2404] update more refs to logj2 version (#2416)
add fa3ca74 [INLONG-2410] Inlong Manager support business workflow suspend | restart | delete (#2412)
No new revisions were added by this update.
Summary of changes:
.../inlong/manager/common/enums/EntityStatus.java | 16 ++-
.../common/model/definition/ServiceTaskType.java | 2 +
.../core/impl/BusinessProcessOperation.java | 130 +++++++++++++++------
.../service/thirdpart/mq/PulsarEventSelector.java | 7 +-
.../service/thirdpart/mq/TubeEventSelector.java | 7 +-
.../thirdpart/sort/ZkSortEventSelector.java | 6 +
.../manager/service/workflow/ProcessName.java | 15 +++
.../workflow/ServiceTaskListenerFactory.java | 6 +
.../manager/service/workflow/WorkflowResult.java | 9 +-
.../business/DeleteBusinessWorkflowDefinition.java | 90 ++++++++++++++
.../RestartBusinessWorkflowDefinition.java | 90 ++++++++++++++
.../SuspendBusinessWorkflowDefinition.java | 91 +++++++++++++++
...owForm.java => UpdateBusinessWorkflowForm.java} | 33 +++---
...stener.java => UpdateBusinessInfoListener.java} | 18 ++-
.../core/impl/BusinessProcessOperationTest.java | 103 ++++++++++++++++
.../service/mocks/MockDeleteSortListener.java} | 32 ++---
.../service/mocks/MockDeleteSourceListener.java} | 32 ++---
.../inlong/manager/service/mocks/MockPlugin.java | 88 ++++++++++++++
.../service/mocks/MockRestartSortListener.java} | 32 ++---
.../service/mocks/MockRestartSourceListener.java} | 32 ++---
.../service/mocks/MockStopSortListener.java} | 32 ++---
.../service/mocks/MockStopSourceListener.java} | 32 ++---
.../service/workflow/WorkflowServiceImplTest.java | 96 ++++++++++++++-
.../manager/web/controller/BusinessController.java | 19 ++-
24 files changed, 848 insertions(+), 170 deletions(-)
create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/business/DeleteBusinessWorkflowDefinition.java
create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/business/RestartBusinessWorkflowDefinition.java
create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/business/SuspendBusinessWorkflowDefinition.java
copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/business/{NewBusinessWorkflowForm.java => UpdateBusinessWorkflowForm.java} (74%)
copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/business/listener/{InitBusinessInfoListener.java => UpdateBusinessInfoListener.java} (83%)
create mode 100644 inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/impl/BusinessProcessOperationTest.java
copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/event/task/SortOperateListener.java => manager-service/src/test/java/org/apache/inlong/manager/service/mocks/MockDeleteSortListener.java} (61%)
copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/event/task/SortOperateListener.java => manager-service/src/test/java/org/apache/inlong/manager/service/mocks/MockDeleteSourceListener.java} (61%)
create mode 100644 inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/mocks/MockPlugin.java
copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/event/task/SortOperateListener.java => manager-service/src/test/java/org/apache/inlong/manager/service/mocks/MockRestartSortListener.java} (61%)
copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/event/task/SortOperateListener.java => manager-service/src/test/java/org/apache/inlong/manager/service/mocks/MockRestartSourceListener.java} (61%)
copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/event/task/SortOperateListener.java => manager-service/src/test/java/org/apache/inlong/manager/service/mocks/MockStopSortListener.java} (62%)
copy inlong-manager/{manager-common/src/main/java/org/apache/inlong/manager/common/event/task/SortOperateListener.java => manager-service/src/test/java/org/apache/inlong/manager/service/mocks/MockStopSourceListener.java} (61%)