- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetAPIPV (0.22 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) GetAPIPV(pvName string) (*v1.PersistentVolume, error) { obj, err := c.GetAPIObj(pvName) if err != nil { return nil, err } pv, ok := obj.(*v1.PersistentVolume) if !ok {
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/binder.go
return false, fmt.Errorf("pod does not exist any more: %w", err) } logger.Error(err, "Failed to get pod from the lister", "pod", klog.KObj(pod)) } for _, binding := range bindings { pv, err := b.pvCache.GetAPIPV(binding.pv.Name) if err != nil { return false, fmt.Errorf("failed to check binding: %w", err) } pvc, err := b.pvcCache.GetAPIPVC(getPVCName(binding.pvc)) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
// All PVs have been unmodified in cache pvCache := env.internalBinder.pvCache for _, b := range bindings { pv, _ := pvCache.GetPV(b.pv.Name) apiPV, _ := pvCache.GetAPIPV(b.pv.Name) // PV could be nil if it's missing from cache if pv != nil && pv != apiPV { t.Errorf("PV %q was modified in cache", b.pv.Name) } } // Check pvc cache
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0)