[inlong] 03/03: [INLONG-8491][Manager] Manager client support list inlong streams with sources and sinks by paginating (#8493)

[vernedeng]

This is an automated email from the ASF dual-hosted git repository.

vernedeng pushed a commit to branch branch-1.8
in repository https://gitbox.apache.org/repos/asf/inlong.git

commit bf8ef83d5aecf2cfa75117b97cc238ad18b79c0c
Author: castor <58140421+castor...@users.noreply.github.com>
AuthorDate: Tue Jul 11 13:04:52 2023 +0800

    [INLONG-8491][Manager] Manager client support list inlong streams with 
sources and sinks by paginating (#8493)
    
    Co-authored-by: castorqin <castor...@tencent.com>
---
 .../client/api/inner/client/InlongStreamClient.java      | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongStreamClient.java
 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongStreamClient.java
index 02f54cb1f7..1709bee418 100644
--- 
a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongStreamClient.java
+++ 
b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongStreamClient.java
@@ -133,6 +133,19 @@ public class InlongStreamClient {
         return response.getData();
     }
 
+    /**
+     * Paging query inlong stream with sources and sinks info list
+     *
+     * @param request query request
+     * @return inlong stream with sources and sinks list
+     */
+    public PageResult<InlongStreamInfo> 
listAllByCondition(InlongStreamPageRequest request) {
+        Response<PageResult<InlongStreamInfo>> pageResultResponse = 
ClientUtils.executeHttpCall(
+                inlongStreamApi.listStream(request));
+        ClientUtils.assertRespSuccess(pageResultResponse);
+        return pageResultResponse.getData();
+    }
+
     /**
      * Get inlong stream info.
      */
@@ -236,7 +249,8 @@ public class InlongStreamClient {
 
     /**
      * Converts a json string to a streamFields
-     *     @param method the method for the field information: json or sql
+     *
+     * @param method the method for the field information: json or sql
      * @param statement the statement for the field information
      * @return list of stream field
      */