This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from eb0c33b61 [INLONG-5874][Agent] Use dataTime to report audit metrics
(#5883)
add 371fc3ff5 [INLONG-5810][Manager] Supplement the workflow event API in
the manager client (#5815)
No new revisions were added by this update.
Summary of changes:
.../client/api/inner/InnerGroupContext.java | 2 +-
.../client/api/inner/client/ClientFactory.java | 2 +
.../client/api/inner/client/InlongGroupClient.java | 2 +-
.../api/inner/client/StreamTransformClient.java | 2 +-
.../api/inner/client/WorkflowEventClient.java | 122 +++++++++++++++++++++
.../client/api/service/WorkflowEventApi.java | 49 ++++++++-
.../inlong/manager/common/enums}/ProcessEvent.java | 4 +-
.../inlong/manager/common/enums}/TaskEvent.java | 4 +-
.../manager/common/enums}/WorkflowEvent.java | 2 +-
.../plugin/listener/DeleteSortListener.java | 2 +-
.../plugin/listener/DeleteStreamListener.java | 2 +-
.../plugin/listener/RestartSortListener.java | 2 +-
.../plugin/listener/RestartStreamListener.java | 2 +-
.../plugin/listener/StartupSortListener.java | 10 +-
.../plugin/listener/StartupStreamListener.java | 2 +-
.../plugin/listener/SuspendSortListener.java | 2 +-
.../plugin/listener/SuspendStreamListener.java | 2 +-
.../manager/service/core/WorkflowEventService.java | 4 +-
.../core/impl/WorkflowEventServiceImpl.java | 4 +-
.../ConsumptionCancelProcessListener.java | 4 +-
.../ConsumptionCompleteProcessListener.java | 2 +-
.../consumption/ConsumptionPassTaskListener.java | 2 +-
.../ConsumptionRejectProcessListener.java | 4 +-
.../listener/group/InitGroupCompleteListener.java | 2 +-
.../listener/group/InitGroupFailedListener.java | 4 +-
.../service/listener/group/InitGroupListener.java | 2 +-
.../group/UpdateGroupCompleteListener.java | 2 +-
.../listener/group/UpdateGroupFailedListener.java | 2 +-
.../listener/group/UpdateGroupListener.java | 2 +-
.../group/apply/AfterApprovedTaskListener.java | 6 +-
.../group/apply/ApproveApplyProcessListener.java | 2 +-
.../group/apply/CancelApplyProcessListener.java | 4 +-
.../group/apply/RejectApplyProcessListener.java | 4 +-
.../listener/queue/QueueResourceListener.java | 2 +-
.../queue/StreamQueueResourceListener.java | 2 +-
.../listener/sink/SinkResourceListener.java | 2 +-
.../listener/sink/StreamSinkResourceListener.java | 2 +-
.../service/listener/sort/SortConfigListener.java | 2 +-
.../listener/sort/StreamSortConfigListener.java | 4 +-
.../source/AbstractSourceOperateListener.java | 2 +-
.../stream/InitStreamCompleteListener.java | 4 +-
.../listener/stream/InitStreamFailedListener.java | 2 +-
.../listener/stream/InitStreamListener.java | 2 +-
.../stream/UpdateStreamCompleteListener.java | 2 +-
.../stream/UpdateStreamFailedListener.java | 2 +-
.../listener/stream/UpdateStreamListener.java | 2 +-
.../service/mocks/MockDeleteSortListener.java | 2 +-
.../service/mocks/MockDeleteSourceListener.java | 2 +-
.../service/mocks/MockRestartSortListener.java | 2 +-
.../service/mocks/MockRestartSourceListener.java | 2 +-
.../service/mocks/MockStopSortListener.java | 2 +-
.../service/mocks/MockStopSourceListener.java | 2 +-
.../service/workflow/WorkflowServiceImplTest.java | 8 +-
.../web/controller/WorkflowEventController.java | 4 +-
.../inlong/manager/workflow/WorkflowAction.java | 2 +-
.../workflow/core/EventListenerService.java | 4 +-
.../core/impl/EventListenerServiceImpl.java | 4 +-
.../workflow/definition/WorkflowProcess.java | 4 +-
.../manager/workflow/definition/WorkflowTask.java | 2 +-
.../manager/workflow/event/EventListener.java | 1 +
.../workflow/event/EventListenerNotifier.java | 1 +
.../workflow/event/LogableEventListener.java | 1 +
.../event/process/LogableProcessEventListener.java | 1 +
.../event/process/ProcessEventListener.java | 1 +
.../event/process/ProcessEventNotifier.java | 1 +
.../event/task/LogableTaskEventListener.java | 1 +
.../workflow/event/task/QueueOperateListener.java | 1 +
.../workflow/event/task/SinkOperateListener.java | 1 +
.../workflow/event/task/SortOperateListener.java | 1 +
.../workflow/event/task/SourceOperateListener.java | 1 +
.../workflow/event/task/TaskEventListener.java | 1 +
.../workflow/event/task/TaskEventNotifier.java | 1 +
.../workflow/processor/EndEventProcessor.java | 2 +-
.../workflow/processor/ServiceTaskProcessor.java | 12 +-
.../workflow/processor/StartEventProcessor.java | 4 +-
.../workflow/processor/UserTaskProcessor.java | 4 +-
76 files changed, 272 insertions(+), 96 deletions(-)
create mode 100644
inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/WorkflowEventClient.java
rename
inlong-manager/{manager-workflow/src/main/java/org/apache/inlong/manager/workflow/event/process
=>
manager-common/src/main/java/org/apache/inlong/manager/common/enums}/ProcessEvent.java
(91%)
rename
inlong-manager/{manager-workflow/src/main/java/org/apache/inlong/manager/workflow/event/task
=>
manager-common/src/main/java/org/apache/inlong/manager/common/enums}/TaskEvent.java
(91%)
rename
inlong-manager/{manager-workflow/src/main/java/org/apache/inlong/manager/workflow/event
=>
manager-common/src/main/java/org/apache/inlong/manager/common/enums}/WorkflowEvent.java
(94%)
