PQA-1860: get edge hosts using continue token (#110)

* get edge hosts using continue token * Update cluster_edge_native.go
spectrocloud · Jun 6, 2024 · cfbbb09 · cfbbb09
1 parent 92d0dd2
commit cfbbb09
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/client/cluster_edge_native.go b/client/cluster_edge_native.go
@@ -53,12 +53,19 @@ func (h *V1Client) GetEdgeHost(edgeHostId string) (*models.V1EdgeHostDevice, err
 }
 
 func (h *V1Client) ListEdgeHosts() ([]*models.V1EdgeHostsMetadata, error) {
-	params := clientV1.NewV1DashboardEdgehostsSearchParamsWithContext(h.ctx)
-	resp, err := h.Client.V1DashboardEdgehostsSearch(params)
-	if err != nil {
-		return nil, err
+	continueToken := ""
+	var items []*models.V1EdgeHostsMetadata
+	for ok := true; ok; ok = (continueToken != "") {
+		params := clientV1.NewV1DashboardEdgehostsSearchParamsWithContext(h.ctx)
+		resp, err := h.Client.V1DashboardEdgehostsSearch(params)
+		if err != nil {
+			return nil, err
+		}
+		continueToken = resp.Payload.Listmeta.Continue
+		items = append(items, resp.Payload.Items...)
 	}
-	return resp.Payload.Items, nil
+
+	return items, nil
 }
 
 func (h *V1Client) CreateClusterEdgeNative(cluster *models.V1SpectroEdgeNativeClusterEntity) (string, error) {