Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 79 for INDEXER (0.14 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/controlplane/controller/legacytokentracking/controller.go

    // feature, existing configmap will be deleted.
    type Controller struct {
    	configMapClient   corev1client.ConfigMapsGetter
    	configMapInformer cache.SharedIndexInformer
    	configMapCache    cache.Indexer
    	configMapSynced   cache.InformerSynced
    	queue             workqueue.TypedRateLimitingInterface[string]
    
    	// rate limiter controls the rate limit of the creation of the configmap.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. 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)
  4. pkg/controller/volume/persistentvolume/index.go

    )
    
    // persistentVolumeOrderedIndex is a cache.Store that keeps persistent volumes
    // indexed by AccessModes and ordered by storage capacity.
    type persistentVolumeOrderedIndex struct {
    	store cache.Indexer
    }
    
    func newPersistentVolumeOrderedIndex() persistentVolumeOrderedIndex {
    	return persistentVolumeOrderedIndex{cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{"accessmodes": accessModesIndexFunc})}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 6.5K bytes
    - Viewed (0)
  5. pkg/scheduler/scheduler_test.go

    						"nodeName": indexByPodAnnotationNodeName,
    					})
    					return &TestPlugin{name: "AddIndexer1"}, err
    				},
    			},
    			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{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  6. 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)
  7. platforms/ide/ide-native/src/testFixtures/groovy/org/gradle/ide/xcode/fixtures/ProjectFile.groovy

                }
            }
    
            void assertIsIndexer() {
                assertIs(ProductType.INDEXER)
                assert this.name.startsWith("[INDEXING ONLY] ")
                this.buildConfigurationList.buildConfigurations.each { buildConfiguration ->
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:12 UTC 2023
    - 11.9K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. README.fr.md

    ![Interface d'administration](https://fess.codelibs.org/_images/fess_admin_dashboard.png)
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Mon Feb 06 22:59:17 UTC 2023
    - 8.3K bytes
    - Viewed (0)
Back to top