Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 528 for listOps (0.3 sec)

  1. pkg/scheduler/framework/listers.go

    	// IsPVCUsedByPods returns true/false on whether the PVC is used by one or more scheduled pods,
    	// keyed in the format "namespace/name".
    	IsPVCUsedByPods(key string) bool
    }
    
    // SharedLister groups scheduler-specific listers.
    type SharedLister interface {
    	NodeInfos() NodeInfoLister
    	StorageInfos() StorageInfoLister
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 04 01:00:41 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/cel/library/lists.go

    //	['a', 'b', 'b', 'c'].lastIndexOf('b') // returns 2
    //	[1.0].indexOf(1.1) // returns -1
    //	[].indexOf('string') // returns -1
    func Lists() cel.EnvOption {
    	return cel.Lib(listsLib)
    }
    
    var listsLib = &lists{}
    
    type lists struct{}
    
    func (*lists) LibraryName() string {
    	return "k8s.lists"
    }
    
    var paramA = cel.TypeParamType("A")
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 23 21:31:27 UTC 2023
    - 9.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/listers/cr/v1/example.go

    	ExampleListerExpansion
    }
    
    // exampleLister implements the ExampleLister interface.
    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.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 11:15:04 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1/customresourcedefinition.go

    type customResourceDefinitionLister struct {
    	listers.ResourceIndexer[*v1.CustomResourceDefinition]
    }
    
    // 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. staging/src/k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1beta1/customresourcedefinition.go

    type customResourceDefinitionLister struct {
    	listers.ResourceIndexer[*v1beta1.CustomResourceDefinition]
    }
    
    // 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)
  6. pkg/scheduler/metrics/resources/resources.go

    package resources
    
    import (
    	"net/http"
    	"strconv"
    
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/resource"
    	"k8s.io/apimachinery/pkg/labels"
    	corelisters "k8s.io/client-go/listers/core/v1"
    	"k8s.io/component-base/metrics"
    
    	v1resource "k8s.io/kubernetes/pkg/api/v1/resource"
    	v1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper"
    )
    
    type resourceLifecycleDescriptors struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 09 23:15:53 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/collect/testing/google/MultimapPutIterableTester.java

        try {
          multimap().putAll(k3(), Lists.newArrayList(v3(), null));
          fail();
        } catch (NullPointerException expected) {
        }
    
        Collection<V> values = multimap().get(k3());
        if (values.size() == 0) {
          expectUnchanged();
          // Be extra thorough in case internal state was corrupted by the expected null.
          assertEquals(Lists.newArrayList(), Lists.newArrayList(values));
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jan 09 20:10:38 UTC 2018
    - 7.6K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/collect/testing/google/MultimapPutIterableTester.java

        try {
          multimap().putAll(k3(), Lists.newArrayList(v3(), null));
          fail();
        } catch (NullPointerException expected) {
        }
    
        Collection<V> values = multimap().get(k3());
        if (values.size() == 0) {
          expectUnchanged();
          // Be extra thorough in case internal state was corrupted by the expected null.
          assertEquals(Lists.newArrayList(), Lists.newArrayList(values));
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jan 09 20:10:38 UTC 2018
    - 7.6K bytes
    - Viewed (0)
  9. pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go

    	coreinformers "k8s.io/client-go/informers/core/v1"
    	"k8s.io/client-go/kubernetes"
    	listers "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    
    	"k8s.io/klog/v2"
    )
    
    // Controller ensure system namespaces exist.
    type Controller struct {
    	client kubernetes.Interface
    
    	namespaceLister listers.NamespaceLister
    	namespaceSynced cache.InformerSynced
    
    	systemNamespaces []string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 12:19:56 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. pkg/controlplane/controller/apiserverleasegc/gc_controller.go

    	informers "k8s.io/client-go/informers/coordination/v1"
    	"k8s.io/client-go/kubernetes"
    	listers "k8s.io/client-go/listers/coordination/v1"
    	"k8s.io/client-go/tools/cache"
    
    	"k8s.io/klog/v2"
    )
    
    // Controller deletes expired apiserver leases.
    type Controller struct {
    	kubeclientset kubernetes.Interface
    
    	leaseLister   listers.LeaseLister
    	leaseInformer cache.SharedIndexInformer
    	leasesSynced  cache.InformerSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 25 03:27:44 UTC 2021
    - 4.6K bytes
    - Viewed (0)
Back to top