in pkg/providers/instance/instance.go [371:385]
func (p *Provider) getNodesByName(ctx context.Context, apName string) ([]*v1.Node, error) {
nodeList := &v1.NodeList{}
labelSelector := client.MatchingLabels{"agentpool": apName, "kubernetes.azure.com/agentpool": apName}
err := retry.OnError(retry.DefaultRetry, func(err error) bool {
return true
}, func() error {
return p.kubeClient.List(ctx, nodeList, labelSelector)
})
if err != nil {
return nil, err
}
return lo.ToSlicePtr(nodeList.Items), nil
}