github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2026-07-23 10:26:22 +00:00
Code Issues Projects Releases Wiki Activity

add err check when plugin init

Browse Source
This commit is contained in:
KunWuLuan
2025-08-21 09:27:11 +08:00
parent edf132e175
commit dd767cdcd6
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/scheduler/framework/plugins/nodevolumelimits/csi.go
View File

@@ -592,13 +592,15 @@ func NewCSI(_ context.Context, _ runtime.Object, handle fwk.Handle, fts feature.
vaLister := informerFactory.Storage().V1().VolumeAttachments().Lister()
csiDriverLister := informerFactory.Storage().V1().CSIDrivers().Lister()
vaindexer := informerFactory.Storage().V1().VolumeAttachments().Informer().GetIndexer()
informerFactory.Storage().V1().VolumeAttachments().Informer().AddIndexers(cache.Indexers{"nodename": func(obj interface{}) ([]string, error) {
if err := informerFactory.Storage().V1().VolumeAttachments().Informer().AddIndexers(cache.Indexers{"nodename": func(obj interface{}) ([]string, error) {
va, ok := obj.(*storagev1.VolumeAttachment)
if !ok {
return []string{}, nil
}
return []string{va.Spec.NodeName}, nil
}})
}}); err != nil {
return nil, fmt.Errorf("failed to add index to VA informer: %w", err)
}
csiTranslator := csitrans.New()
return &CSILimits{