- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ListPVs (0.16 sec)
-
pkg/scheduler/framework/plugins/volumebinding/assume_cache.go
return nil, err } pv, ok := obj.(*v1.PersistentVolume) if !ok { return nil, &assumecache.WrongTypeError{TypeName: "v1.PersistentVolume", Object: obj} } return pv, nil } func (c *PVAssumeCache) ListPVs(storageClassName string) []*v1.PersistentVolume { objs := c.List(&v1.PersistentVolume{ Spec: v1.PersistentVolumeSpec{ StorageClassName: storageClassName, }, }) pvs := []*v1.PersistentVolume{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/assume_cache_test.go
pvList := cache.ListPVs(storageClassName) if len(pvList) != len(expectedPVs) { t.Errorf("ListPVs() returned %v PVs, expected %v", len(pvList), len(expectedPVs)) } for _, pv := range pvList { expectedPV, ok := expectedPVs[pv.Name] if !ok { t.Errorf("ListPVs() returned unexpected PV %q", pv.Name) } if expectedPV != pv { t.Errorf("ListPVs() returned PV %p, expected %p", pv, expectedPV) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
// Get storage class name from each PVC storageClassName := volume.GetPersistentVolumeClaimClass(pvc) podVolumeClaims.unboundVolumesDelayBinding[storageClassName] = b.pvCache.ListPVs(storageClassName) } return podVolumeClaims, nil } func (b *volumeBinder) checkBoundClaims(logger klog.Logger, claims []*v1.PersistentVolumeClaim, node *v1.Node, pod *v1.Pod) (bool, bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0)