Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for GetPVC (0.15 sec)

  1. pkg/scheduler/framework/plugins/volumebinding/assume_cache_test.go

    		},
    	}
    }
    
    func verifyPVC(cache *PVCAssumeCache, pvcKey string, expectedPVC *v1.PersistentVolumeClaim) error {
    	pvc, err := cache.GetPVC(pvcKey)
    	if err != nil {
    		return err
    	}
    	if pvc != expectedPVC {
    		return fmt.Errorf("GetPVC() returned %p, expected %p", pvc, expectedPVC)
    	}
    	return nil
    }
    
    func TestAssumePVC(t *testing.T) {
    	logger, _ := ktesting.NewTestContext(t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  2. pkg/api/persistentvolumeclaim/util_test.go

    			enableRecoverVolumeExpansionFailure: false,
    			enableVolumeAttributesClass:         false,
    			pvc:                                 withAllocatedResource("5G"),
    			oldPVC:                              getPVC(),
    			expected:                            getPVC(),
    		},
    		{
    			name:                                "for:newPVC=hasAllocatedResource,oldPVC=doesnot,featuregate=RecoverVolumeExpansionFailure=true; should keep field",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumebinding/assume_cache.go

    	return &PVCAssumeCache{
    		AssumeCache: assumecache.NewAssumeCache(logger, informer, "v1.PersistentVolumeClaim", "", nil),
    		logger:      logger,
    	}
    }
    
    func (c *PVCAssumeCache) GetPVC(pvcKey string) (*v1.PersistentVolumeClaim, error) {
    	obj, err := c.Get(pvcKey)
    	if err != nil {
    		return nil, err
    	}
    
    	pvc, ok := obj.(*v1.PersistentVolumeClaim)
    	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)
  4. pkg/scheduler/framework/plugins/volumebinding/binder_test.go

    		}
    	}
    
    	// Check pvc cache
    	pvcCache := env.internalBinder.pvcCache
    	for _, p := range provisionings {
    		pvcKey := getPVCName(p)
    		pvc, err := pvcCache.GetPVC(pvcKey)
    		if err != nil {
    			t.Errorf("GetPVC %q returned error: %v", pvcKey, err)
    			continue
    		}
    		if pvc.Annotations[volume.AnnSelectedNode] != nodeLabelValue {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/volumebinding/binder.go

    	claim := &v1.PersistentVolumeClaim{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      pvcName,
    			Namespace: namespace,
    		},
    	}
    	pvcKey := getPVCName(claim)
    	pvc, err := b.pvcCache.GetPVC(pvcKey)
    	if err != nil || pvc == nil {
    		return false, nil, fmt.Errorf("error getting PVC %q: %v", pvcKey, err)
    	}
    
    	fullyBound := b.isPVCFullyBound(pvc)
    	if fullyBound {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 42.6K bytes
    - Viewed (0)
Back to top