- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for assumeCache (0.22 sec)
-
pkg/scheduler/framework/plugins/volumebinding/assume_cache.go
"fmt" "k8s.io/klog/v2" v1 "k8s.io/api/core/v1" storagehelpers "k8s.io/component-helpers/storage/volume" "k8s.io/kubernetes/pkg/scheduler/util/assumecache" ) // PVAssumeCache is a AssumeCache for PersistentVolume objects type PVAssumeCache struct { *assumecache.AssumeCache logger klog.Logger } func pvStorageClassIndexFunc(obj interface{}) ([]string, error) { if pv, ok := obj.(*v1.PersistentVolume); 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/util/assumecache/assume_cache_test.go
tCtx.Fatalf("GetAPIObject() returned %v, expected %v", actualAPIObject, expectedAPIObject) } } func verifyList(tCtx ktesting.TContext, assumeCache *AssumeCache, expectedObjs []interface{}, indexObj interface{}) { actualObjs := assumeCache.List(indexObj) diff := cmp.Diff(expectedObjs, actualObjs, cmpopts.SortSlices(func(x, y interface{}) bool { xKey, err := cache.MetaNamespaceKeyFunc(x) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/structuredparameters.go
// newResourceModel. type resourceSliceLister interface { List(selector labels.Selector) (ret []*resourcev1alpha2.ResourceSlice, err error) } // assumeCacheLister is the subset of volumebinding.AssumeCache needed by newResourceModel. type assumeCacheLister interface { List(indexObj interface{}) []interface{} } // newResourceModel parses the available information about resources. Objects
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 22 09:03:22 UTC 2024 - 8.7K bytes - Viewed (0)