You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by he...@apache.org on 2022/11/09 09:37:46 UTC

[inlong] branch master updated (55349721f -> 7e391ea96)

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 55349721f [INLONG-6475][Docker] Add a base flink environment for docker-compose (#6476)
     add 7e391ea96 [INLONG-6477][Manager] Add consume API in the manager client (#6480)

No new revisions were added by this update.

Summary of changes:
 .../inlong/manager/client/api/InlongConsume.java}  |  60 ++------
 .../manager/client/api/impl/InlongConsumeImpl.java |  89 ++++++++++++
 .../client/api/inner/client/ClientFactory.java     |   2 +
 .../api/inner/client/InlongConsumeClient.java      | 147 +++++++++++++++++++
 .../{DataNodeApi.java => InlongConsumeApi.java}    |  39 ++---
 .../client/api/inner/ClientFactoryTest.java        |   3 +
 .../client/api/inner/InlongConsumeClientTest.java  | 160 +++++++++++++++++++++
 .../web/controller/InlongConsumeController.java    |   5 +-
 8 files changed, 439 insertions(+), 66 deletions(-)
 copy inlong-manager/{manager-service/src/main/java/org/apache/inlong/manager/service/consume/InlongConsumeService.java => manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongConsume.java} (59%)
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongConsumeImpl.java
 create mode 100644 inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongConsumeClient.java
 copy inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/{DataNodeApi.java => InlongConsumeApi.java} (53%)
 create mode 100644 inlong-manager/manager-client/src/test/java/org/apache/inlong/manager/client/api/inner/InlongConsumeClientTest.java