diff --git a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongClusterClient.java b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongClusterClient.java index ccae50d6cc6..a4558b43add 100644 --- a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongClusterClient.java +++ b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongClusterClient.java @@ -154,6 +154,19 @@ public PageResult list(ClusterPageRequest request) { return response.getData(); } + /** + * Paging query clusters according to tenant role. + * + * @param request query conditions + * @return cluster list + */ + public PageResult listByTenantRole(ClusterPageRequest request) { + Response> response = + ClientUtils.executeHttpCall(inlongClusterApi.listByTenantRole(request)); + ClientUtils.assertRespSuccess(response); + return response.getData(); + } + /** * Update cluster information. * diff --git a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongClusterApi.java b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongClusterApi.java index a83a6a0f2af..5be602cc3b1 100644 --- a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongClusterApi.java +++ b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongClusterApi.java @@ -66,6 +66,9 @@ public interface InlongClusterApi { @POST("cluster/list") Call>> list(@Body ClusterPageRequest request); + @POST("cluster/listByTenantRole") + Call>> listByTenantRole(@Body ClusterPageRequest request); + @POST("cluster/update") Call> update(@Body ClusterRequest request);