Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 70 for Indexer (0.33 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/lister.go

    	return result, nil
    }
    
    func (w lister[T]) Namespaced(namespace string) NamespacedLister[T] {
    	return namespacedLister[T]{namespace: namespace, indexer: w.indexer}
    }
    
    func NewLister[T runtime.Object](indexer cache.Indexer) lister[T] {
    	return lister[T]{indexer: indexer}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/interface.go

    	HasSynced() bool
    }
    
    type NamespacedLister[T any] interface {
    	// List lists all ValidationRuleSets in the indexer for a given namespace.
    	// Objects returned here must be treated as read-only.
    	List(selector labels.Selector) (ret []T, err error)
    	// Get retrieves the ValidationRuleSet from the indexer for a given namespace and name.
    	// Objects returned here must be treated as read-only.
    	Get(name string) (T, error)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  7. 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)
  8. src/main/java/org/codelibs/fess/indexer/DocBoostMatcher.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.indexer;
    
    import java.util.Map;
    
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.es.config.exentity.BoostDocumentRule;
    import org.codelibs.fess.util.ComponentUtil;
    
    public class DocBoostMatcher {
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/suggest/SuggesterBuilderTest.java

            final Suggester suggester = Suggester.builder().build(runner.client(), id);
    
            assertNotNull(suggester);
            assertNotNull(suggester.client);
            assertNotNull(suggester.indexer());
            assertNotNull(suggester.getNormalizer());
            assertNotNull(suggester.getReadingConverter());
            assertNotNull(suggester.settings());
            assertTrue(!Strings.isNullOrEmpty(suggester.index));
        }
    Registered: Wed Jun 12 15:38:08 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/indexer/DocBoostMatcherTest.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.indexer;
    
    import java.util.HashMap;
    import java.util.Map;
    
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.exception.JobProcessingException;
    import org.codelibs.fess.script.AbstractScriptEngine;
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top