- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 354 for Indexer (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/resource_access.go
items, err := e.lister.ResourceQuotas(namespace).List(labels.Everything()) if err != nil { return nil, fmt.Errorf("error resolving quota: %v", err) } // if there are no items held in our indexer, check our live-lookup LRU, if that misses, do the live lookup to prime it. if len(items) == 0 { lruItemObj, ok := e.liveLookupCache.Get(namespace) if !ok || lruItemObj.(liveLookupEntry).expiry.Before(time.Now()) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 13:54:56 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/serviceaccount/jwt_test.go
} } func newIndexer(get func(namespace, name string) (interface{}, error)) cache.Indexer { return &fakeIndexer{get: get} } type fakeIndexer struct { cache.Indexer get func(namespace, name string) (interface{}, error) } func (f *fakeIndexer) GetByKey(key string) (interface{}, bool, error) { parts := strings.SplitN(key, "/", 2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 22:16:08 UTC 2024 - 17K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
}, }, wantErr: "indexer conflict", }, { name: "register the same indexer body with different names, no conflicts", // order of registration doesn't matter entrypoints: map[string]frameworkruntime.PluginFactory{ "AddIndexer1": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
pvcLister corelisters.PersistentVolumeClaimLister pvcListerSynced cache.InformerSynced podLister corelisters.PodLister podListerSynced cache.InformerSynced podIndexer cache.Indexer queue workqueue.TypedRateLimitingInterface[string] } // NewPVCProtectionController returns a new instance of PVCProtectionController.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
security/pkg/server/ca/node_auth.go
} // We want to find out if there is any pod running with the requested identity on the callers node. // The indexer (previously setup) creates a lookup table for a {Node, SA} pair, which we can lookup k := SaNode{ ServiceAccount: types.NamespacedName{Name: requestedIdentity.ServiceAccount, Namespace: requestedIdentity.Namespace},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 6.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/Suggester.java
} client.admin().indices().prepareDelete(s).execute().actionGet(suggestSettings.getIndicesTimeout()); }); } public SuggestIndexer indexer() { return createDefaultIndexer(); } public static SuggesterBuilder builder() { return new SuggesterBuilder(); } // getter public SuggestSettings settings() {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 14.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_test.go
makeStorageClass(classExternal, &modeImmediate), } storageClasses[0].Provisioner = "gcr.io/vendor-csi" indexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{}) for _, class := range storageClasses { indexer.Add(class) } ctrl.classLister = storagelisters.NewStorageClassLister(indexer) reactor := newVolumeReactor(ctx, client, ctrl, fakeVolumeWatch, fakeClaimWatch, test.errors)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/scheduler/util/assumecache/assume_cache.go
logger: logger, description: description, indexFunc: indexFunc, indexName: indexName, } indexers := cache.Indexers{} if indexName != "" && indexFunc != nil { indexers[indexName] = c.objInfoIndexFunc } c.store = cache.NewIndexer(objInfoKeyFunc, indexers) // Unit tests don't use informers if informer != nil { // Cannot fail in practice?! No-one bothers checking the error.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 10.6K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
templateLister resourcev1alpha2listers.ResourceClaimTemplateLister templatesSynced cache.InformerSynced // podIndexer has the common PodResourceClaim indexer indexer installed To // limit iteration over pods to those of interest. podIndexer cache.Indexer // recorder is used to record events in the API server recorder record.EventRecorder queue workqueue.TypedRateLimitingInterface[string]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
// claimParametersIndexer has the common claimParametersGeneratedFrom indexer installed to // limit iteration over claimParameters to those of interest. claimParametersIndexer cache.Indexer // classParametersIndexer has the common classParametersGeneratedFrom indexer installed to // limit iteration over classParameters to those of interest. classParametersIndexer cache.Indexer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0)