Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetAPIPV (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top