Skip to content

Commit c1e0771

Browse files
committed
Remove redundant pagination
Signed-off-by: Stefan Büringer [email protected]
1 parent 3428336 commit c1e0771

File tree

2 files changed

+16
-26
lines changed

2 files changed

+16
-26
lines changed

exp/internal/controllers/machinepool_controller_phases.go

Lines changed: 9 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -559,23 +559,18 @@ func (r *MachinePoolReconciler) getNodeRefMap(ctx context.Context, c client.Clie
559559
log := ctrl.LoggerFrom(ctx)
560560
nodeRefsMap := make(map[string]*corev1.Node)
561561
nodeList := corev1.NodeList{}
562-
for {
563-
if err := c.List(ctx, &nodeList, client.Continue(nodeList.Continue)); err != nil {
564-
return nil, err
565-
}
566-
567-
for _, node := range nodeList.Items {
568-
if node.Spec.ProviderID == "" {
569-
log.V(2).Info("No ProviderID detected, skipping", "providerID", node.Spec.ProviderID)
570-
continue
571-
}
562+
// Note: We don't use pagination as this is a cached client and a cached client doesn't support pagination.
563+
if err := c.List(ctx, &nodeList); err != nil {
564+
return nil, err
565+
}
572566

573-
nodeRefsMap[node.Spec.ProviderID] = &node
567+
for _, node := range nodeList.Items {
568+
if node.Spec.ProviderID == "" {
569+
log.V(2).Info("No ProviderID detected, skipping", "providerID", node.Spec.ProviderID)
570+
continue
574571
}
575572

576-
if nodeList.Continue == "" {
577-
break
578-
}
573+
nodeRefsMap[node.Spec.ProviderID] = &node
579574
}
580575

581576
return nodeRefsMap, nil

internal/controllers/machine/machine_controller_noderef.go

Lines changed: 7 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -254,19 +254,14 @@ func (r *Reconciler) getNode(ctx context.Context, c client.Reader, providerID st
254254
if len(nodeList.Items) == 0 {
255255
// If for whatever reason the index isn't registered or available, we fallback to loop over the whole list.
256256
nl := corev1.NodeList{}
257-
for {
258-
if err := c.List(ctx, &nl, client.Continue(nl.Continue)); err != nil {
259-
return nil, err
260-
}
261-
262-
for _, node := range nl.Items {
263-
if providerID == node.Spec.ProviderID {
264-
return &node, nil
265-
}
266-
}
257+
// Note: We don't use pagination as this is a cached client and a cached client doesn't support pagination.
258+
if err := c.List(ctx, &nl); err != nil {
259+
return nil, err
260+
}
267261

268-
if nl.Continue == "" {
269-
break
262+
for _, node := range nl.Items {
263+
if providerID == node.Spec.ProviderID {
264+
return &node, nil
270265
}
271266
}
272267

0 commit comments

Comments
 (0)