Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for Indexer (0.16 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/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)
  6. 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)
  7. cmd/metacache-bucket.go

    )
    
    // a bucketMetacache keeps track of all caches generated
    // for a bucket.
    type bucketMetacache struct {
    	// Name of bucket
    	bucket string
    
    	// caches indexed by id.
    	caches map[string]metacache
    	// cache ids indexed by root paths
    	cachesRoot map[string][]string `msg:"-"`
    
    	// Internal state
    	mu      sync.RWMutex `msg:"-"`
    	updated bool         `msg:"-"`
    }
    
    type deleteAllStorager interface {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. pkg/config/schema/kubeclient/common.go

    				},
    			},
    			&unstructured.Unstructured{},
    			cache.SharedIndexInformerOptions{
    				ResyncPeriod:      0,
    				Indexers:          cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc},
    				ObjectDescription: g.String(),
    			},
    		)
    		setupInformer(opts, inf)
    		return inf
    	})
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 16:38:40 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  9. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/PersistentCache.java

        /**
         * Returns the base directory for this cache.
         */
        @Override
        File getBaseDir();
    
        /**
         * Creates an indexed cache implementation that is contained within this cache. This method may be used at any time.
         *
         * <p>The returned cache may only be used by an action being run from {@link #useCache(java.util.function.Supplier)}.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 19 07:59:23 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  10. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSet.java

          return new ImmutableAsList<E>() {
            @Override
            public E get(int index) {
              return Indexed.this.get(index);
            }
    
            @Override
            Indexed<E> delegateCollection() {
              return Indexed.this;
            }
          };
        }
      }
    
      public static <E> Builder<E> builder() {
        return new Builder<E>();
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 08 03:01:02 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top