Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 203 for Indexer (0.29 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/listers/cr/v1/example.go

    type exampleLister struct {
    	listers.ResourceIndexer[*v1.Example]
    }
    
    // NewExampleLister returns a new ExampleLister.
    func NewExampleLister(indexer cache.Indexer) ExampleLister {
    	return &exampleLister{listers.New[*v1.Example](indexer, v1.Resource("example"))}
    }
    
    // Examples returns an object that can list and get Examples.
    func (s *exampleLister) Examples(namespace string) ExampleNamespaceLister {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 11:15:04 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1beta1/customresourcedefinition.go

    }
    
    // NewCustomResourceDefinitionLister returns a new CustomResourceDefinitionLister.
    func NewCustomResourceDefinitionLister(indexer cache.Indexer) CustomResourceDefinitionLister {
    	return &customResourceDefinitionLister{listers.New[*v1beta1.CustomResourceDefinition](indexer, v1beta1.Resource("customresourcedefinition"))}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 11:15:04 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go

    type indexValidator func(int) bool
    
    func newCacheInterval(startIndex, endIndex int, indexer indexerFunc, indexValidator indexValidator, locker sync.Locker) *watchCacheInterval {
    	return &watchCacheInterval{
    		startIndex:     startIndex,
    		endIndex:       endIndex,
    		indexer:        indexer,
    		indexValidator: indexValidator,
    		buffer:         &watchCacheIntervalBuffer{buffer: make([]*watchCacheEvent, bufferSize)},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1/customresourcedefinition.go

    }
    
    // NewCustomResourceDefinitionLister returns a new CustomResourceDefinitionLister.
    func NewCustomResourceDefinitionLister(indexer cache.Indexer) CustomResourceDefinitionLister {
    	return &customResourceDefinitionLister{listers.New[*v1.CustomResourceDefinition](indexer, v1.Resource("customresourcedefinition"))}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 11:15:04 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  5. pkg/controller/statefulset/stateful_pod_control_test.go

    	fakeClient := &fake.Clientset{}
    	claims := getPersistentVolumeClaims(set, pod)
    	indexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
    	for k := range claims {
    		claim := claims[k]
    		indexer.Add(&claim)
    	}
    	claimLister := corelisters.NewPersistentVolumeClaimLister(indexer)
    	control := NewStatefulPodControl(fakeClient, nil, claimLister, recorder)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
  6. src/main/resources/fess_config.properties

    crawler.document.cache.html.mimetypes=text/html
    
    # indexer
    indexer.thread.dump.enabled=true
    indexer.unprocessed.document.size=1000
    indexer.click.count.enabled=true
    indexer.favorite.count.enabled=true
    indexer.webfs.commit.margin.time=5000
    indexer.webfs.max.empty.list.count=3600
    indexer.webfs.update.interval=10000
    indexer.webfs.max.document.cache.size=10
    indexer.webfs.max.document.request.size=1048576
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Apr 11 02:34:53 UTC 2024
    - 30.6K bytes
    - Viewed (0)
  7. pkg/registry/flowcontrol/ensurer/prioritylevelconfiguration_test.go

    			indexer := toolscache.NewIndexer(toolscache.MetaNamespaceKeyFunc, toolscache.Indexers{})
    			if test.current != nil {
    				client.Create(context.TODO(), test.current, metav1.CreateOptions{})
    				indexer.Add(test.current)
    			}
    
    			ops := NewPriorityLevelConfigurationOps(client, flowcontrollisters.NewPriorityLevelConfigurationLister(indexer))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 14:34:53 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  8. pkg/controller/volume/ephemeral/controller.go

    	podLister corelisters.PodLister
    	podSynced cache.InformerSynced
    
    	// podIndexer has the common PodPVC 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: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. plugin/pkg/admission/resourcequota/admission_test.go

    	}
    
    	handler, err := createHandlerWithConfig(kubeClient, informerFactory, config, stopCh)
    	if err != nil {
    		t.Errorf("Error occurred while creating admission plugin: %v", err)
    	}
    
    	indexer.Add(resourceQuota1)
    	indexer.Add(resourceQuota2)
    	newPod := validPod("allowed-pod", 1, getResourceRequirements(getResourceList("3", "2Gi"), getResourceList("", "")))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 84.1K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go

    	startIndex, endIndex, locker := 0, len(events), &sync.Mutex{}
    	indexer := func(i int) *watchCacheEvent {
    		if len(events) == 0 {
    			return nil
    		}
    		return events[i]
    	}
    	indexValidator := func(_ int) bool { return true }
    
    	return newCacheInterval(startIndex, endIndex, indexer, indexValidator, locker)
    }
    
    func bufferFromEvents(events []*watchCacheEvent) *watchCacheIntervalBuffer {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 11.6K bytes
    - Viewed (0)
Back to top