- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewPVAssumeCache (0.29 sec)
-
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) -
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) -
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)