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
