Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewPVAssumeCache (0.29 sec)

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

    		return []string{storagehelpers.GetPersistentVolumeClass(pv)}, nil
    	}
    	return []string{""}, fmt.Errorf("object is not a v1.PersistentVolume: %v", obj)
    }
    
    // NewPVAssumeCache creates a PV assume cache.
    func NewPVAssumeCache(logger klog.Logger, informer assumecache.Informer) *PVAssumeCache {
    	logger = klog.LoggerWithName(logger, "PV Cache")
    	return &PVAssumeCache{
    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/assume_cache_test.go

    			newPV:         makePV("pv1", "").withVersion("5").PersistentVolume,
    			shouldSucceed: false,
    		},
    	}
    
    	for name, scenario := range scenarios {
    		cache := NewPVAssumeCache(logger, nil)
    
    		// Add oldPV to cache
    		assumecache.AddTestObject(cache.AssumeCache, scenario.oldPV)
    		if err := verifyPV(cache, scenario.oldPV.Name, scenario.oldPV); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumebinding/binder.go

    		classLister:   storageClassInformer.Lister(),
    		nodeLister:    nodeInformer.Lister(),
    		csiNodeLister: csiNodeInformer.Lister(),
    		pvcCache:      NewPVCAssumeCache(logger, pvcInformer.Informer()),
    		pvCache:       NewPVAssumeCache(logger, pvInformer.Informer()),
    		bindTimeout:   bindTimeout,
    		translator:    csitrans.New(),
    	}
    
    	b.csiDriverLister = capacityCheck.CSIDriverInformer.Lister()
    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