[incubator-inlong] branch master updated (9ad1bc8c6 -> f8c84bc78)

[he...@apache.org]

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%)