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/incubator-inlong.git
from 9ad1bc8c6 [INLONG-4532][Manager] Fix init the sort config error in the
client (#4533)
add f8c84bc78 [INLONG-4541][Manager] Support save extension params for
inlong cluster (#4542)
No new revisions were added by this update.
Summary of changes:
.../inlong/manager/common/enums/ClusterType.java | 21 ++-
...ClusterResponse.java => InlongClusterInfo.java} | 17 +-
.../common/pojo/cluster/InlongClusterRequest.java | 8 +
.../dataproxy/DataProxyClusterInfo.java} | 22 +--
.../dataproxy/DataProxyClusterRequest.java} | 18 +-
.../pojo/cluster/pulsar/PulsarClusterDTO.java | 10 ++
.../pulsar/PulsarClusterInfo.java} | 33 ++--
.../pulsar/PulsarClusterRequest.java} | 25 +--
.../tube/TubeClusterInfo.java} | 22 +--
.../tube/TubeClusterRequest.java} | 18 +-
.../service/cluster/AbstractClusterOperator.java | 73 ++++++++
.../service/cluster/DataProxyClusterOperator.java | 63 +++++++
.../service/cluster/InlongClusterOperator.java | 66 +++++++
.../InlongClusterOperatorFactory.java} | 21 ++-
.../{core => cluster}/InlongClusterService.java | 24 +--
.../impl => cluster}/InlongClusterServiceImpl.java | 89 +++++-----
.../service/cluster/PulsarClusterOperator.java | 88 ++++++++++
.../TubeClusterOperator.java} | 45 ++---
.../impl => cluster}/InlongClusterServiceTest.java | 191 ++++++++-------------
.../service/core/impl/ConsumptionServiceTest.java | 1 +
.../service/core/impl/InlongStreamServiceTest.java | 1 +
.../impl => group}/InlongGroupServiceTest.java | 5 +-
.../web/controller/InlongClusterController.java | 8 +-
.../web/controller/openapi/AgentController.java | 2 +-
.../controller/openapi/DataProxyController.java | 2 +-
.../controller/openapi/OpenClusterController.java | 8 +-
26 files changed, 575 insertions(+), 306 deletions(-)
rename
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/cluster/{InlongClusterResponse.java
=> InlongClusterInfo.java} (81%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{group/none/InlongNoneMqInfo.java
=> cluster/dataproxy/DataProxyClusterInfo.java} (65%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{group/tube/InlongTubeRequest.java
=> cluster/dataproxy/DataProxyClusterRequest.java} (68%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{group/tube/InlongTubeInfo.java
=> cluster/pulsar/PulsarClusterInfo.java} (60%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{source/autopush/AutoPushSourceRequest.java
=> cluster/pulsar/PulsarClusterRequest.java} (62%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{group/none/InlongNoneMqInfo.java
=> cluster/tube/TubeClusterInfo.java} (67%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{group/tube/InlongTubeRequest.java
=> cluster/tube/TubeClusterRequest.java} (70%)
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/AbstractClusterOperator.java
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/DataProxyClusterOperator.java
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterOperator.java
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/{source/SourceOperationFactory.java
=> cluster/InlongClusterOperatorFactory.java} (62%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/{core
=> cluster}/InlongClusterService.java (95%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/{core/impl
=> cluster}/InlongClusterServiceImpl.java (93%)
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/PulsarClusterOperator.java
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/{group/InlongNoneMqOperator.java
=> cluster/TubeClusterOperator.java} (50%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core/impl
=> cluster}/InlongClusterServiceTest.java (55%)
rename
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/{core/impl
=> group}/InlongGroupServiceTest.java (97%)
