Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 354 for Indexer (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top