mirrors/node-feature-discovery
mirrors/node-feature-discovery
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/node-feature-discovery.git synced 2025-03-31 04:04:51 +00:00
Code Activity

fix listing to paginate continue

Browse source
This commit is contained in:
Igor Velichkovich 2025-01-04 19:27:32 -08:00
parent 931b61afac
commit a2f73944ea
1 changed files with 18 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
api/generated/informers/externalversions/nfd/v1alpha1/nodefeature.go
View file

@ -20,6 +20,7 @@ package v1alpha1
import (
context "context"
"go.uber.org/zap"
time "time"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@ -62,7 +63,23 @@ func NewFilteredNodeFeatureInformer(client versioned.Interface, namespace string
if tweakListOptions != nil {
tweakListOptions(&options)
}
return client.NfdV1alpha1().NodeFeatures(namespace).List(context.TODO(), options)
if options.Limit == 0 {
return client.NfdV1alpha1().NodeFeatures(namespace).List(context.TODO(), options)
}
featureList := &apinfdv1alpha1.NodeFeatureList{}
// do paginated list
for {
features, err := client.NfdV1alpha1().NodeFeatures(namespace).List(context.TODO(), options)
if err != nil {
return nil, err
}
featureList.Items = append(featureList.Items, features.Items...)
if features.Continue == "" {
break
}
options.Continue = features.Continue
}
return featureList, nil
},
WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
if tweakListOptions != nil {