Skip to content

Commit 817e678

Browse files
committed
cks: fix list apis count
Fixes count value in listKubernetesClusters and listSupportedKubernetesVersions APIs response. Signed-off-by: Abhishek Kumar <abhishek.mrt22@gmail.com>
1 parent e09fd2e commit 817e678

2 files changed

Lines changed: 13 additions & 9 deletions

File tree

plugins/integrations/kubernetes-service/src/main/java/com/cloud/kubernetes/cluster/KubernetesClusterManagerImpl.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1287,13 +1287,13 @@ public ListResponse<KubernetesClusterResponse> listKubernetesClusters(ListKubern
12871287
if (name != null) {
12881288
sc.setParameters("name", name);
12891289
}
1290-
List<KubernetesClusterVO> kubernetesClusters = kubernetesClusterDao.search(sc, searchFilter);
1291-
for (KubernetesClusterVO cluster : kubernetesClusters) {
1290+
Pair<List<KubernetesClusterVO>, Integer> kubernetesClustersAndCount = kubernetesClusterDao.searchAndCount(sc, searchFilter);
1291+
for (KubernetesClusterVO cluster : kubernetesClustersAndCount.first()) {
12921292
KubernetesClusterResponse clusterResponse = createKubernetesClusterResponse(cluster.getId());
12931293
responsesList.add(clusterResponse);
12941294
}
1295-
ListResponse<KubernetesClusterResponse> response = new ListResponse<KubernetesClusterResponse>();
1296-
response.setResponses(responsesList);
1295+
ListResponse<KubernetesClusterResponse> response = new ListResponse<>();
1296+
response.setResponses(responsesList, kubernetesClustersAndCount.second());
12971297
return response;
12981298
}
12991299

plugins/integrations/kubernetes-service/src/main/java/com/cloud/kubernetes/version/KubernetesVersionManagerImpl.java

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@
5252
import com.cloud.template.TemplateApiService;
5353
import com.cloud.template.VirtualMachineTemplate;
5454
import com.cloud.user.AccountManager;
55+
import com.cloud.utils.Pair;
5556
import com.cloud.utils.component.ComponentContext;
5657
import com.cloud.utils.component.ManagerBase;
5758
import com.cloud.utils.db.Filter;
@@ -111,13 +112,14 @@ private KubernetesSupportedVersionResponse createKubernetesSupportedVersionRespo
111112
return response;
112113
}
113114

114-
private ListResponse<KubernetesSupportedVersionResponse> createKubernetesSupportedVersionListResponse(List<KubernetesSupportedVersionVO> versions) {
115+
private ListResponse<KubernetesSupportedVersionResponse> createKubernetesSupportedVersionListResponse(
116+
List<KubernetesSupportedVersionVO> versions, Integer count) {
115117
List<KubernetesSupportedVersionResponse> responseList = new ArrayList<>();
116118
for (KubernetesSupportedVersionVO version : versions) {
117119
responseList.add(createKubernetesSupportedVersionResponse(version));
118120
}
119121
ListResponse<KubernetesSupportedVersionResponse> response = new ListResponse<>();
120-
response.setResponses(responseList);
122+
response.setResponses(responseList, count);
121123
return response;
122124
}
123125

@@ -272,10 +274,12 @@ public ListResponse<KubernetesSupportedVersionResponse> listKubernetesSupportedV
272274
if(keyword != null){
273275
sc.setParameters("keyword", "%" + keyword + "%");
274276
}
275-
List <KubernetesSupportedVersionVO> versions = kubernetesSupportedVersionDao.search(sc, searchFilter);
276-
versions = filterKubernetesSupportedVersions(versions, minimumSemanticVersion);
277+
Pair<List<KubernetesSupportedVersionVO>, Integer> versionsAndCount =
278+
kubernetesSupportedVersionDao.searchAndCount(sc, searchFilter);
279+
List<KubernetesSupportedVersionVO> versions =
280+
filterKubernetesSupportedVersions(versionsAndCount.first(), minimumSemanticVersion);
277281

278-
return createKubernetesSupportedVersionListResponse(versions);
282+
return createKubernetesSupportedVersionListResponse(versions, versionsAndCount.second());
279283
}
280284

281285
@Override

0 commit comments

Comments
 (0)