Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for corev1lister (2.57 sec)

  1. plugin/pkg/admission/noderestriction/admission_test.go

    		existingNodes      = corev1lister.NewNodeLister(existingNodesIndex)
    
    		noExistingPodsIndex = cache.NewIndexer(cache.MetaNamespaceKeyFunc, nil)
    		noExistingPods      = corev1lister.NewPodLister(noExistingPodsIndex)
    
    		existingPodsIndex = cache.NewIndexer(cache.MetaNamespaceKeyFunc, nil)
    		existingPods      = corev1lister.NewPodLister(existingPodsIndex)
    
    		labelsA = map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 73.2K bytes
    - Viewed (0)
  2. plugin/pkg/admission/noderestriction/admission.go

    	}
    }
    
    // Plugin holds state for and implements the admission plugin.
    type Plugin struct {
    	*admission.Handler
    	nodeIdentifier nodeidentifier.NodeIdentifier
    	podsGetter     corev1lister.PodLister
    	nodesGetter    corev1lister.NodeLister
    
    	expansionRecoveryEnabled         bool
    	dynamicResourceAllocationEnabled bool
    }
    
    var (
    	_ admission.Interface                                 = &Plugin{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  3. plugin/pkg/auth/authenticator/token/bootstrap/bootstrap.go

    //
    // Lister is expected to be for the "kube-system" namespace.
    func NewTokenAuthenticator(lister corev1listers.SecretNamespaceLister) *TokenAuthenticator {
    	return &TokenAuthenticator{lister}
    }
    
    // TokenAuthenticator authenticates bootstrap tokens from secrets in the API server.
    type TokenAuthenticator struct {
    	lister corev1listers.SecretNamespaceLister
    }
    
    // tokenErrorf prints a error message for a secret that has matched a bearer
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 30 20:38:15 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  4. plugin/pkg/admission/namespace/autoprovision/admission.go

    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apiserver/pkg/admission"
    	genericadmissioninitializer "k8s.io/apiserver/pkg/admission/initializer"
    	"k8s.io/client-go/informers"
    	"k8s.io/client-go/kubernetes"
    	corev1listers "k8s.io/client-go/listers/core/v1"
    	api "k8s.io/kubernetes/pkg/apis/core"
    )
    
    // PluginName indicates name of admission plugin.
    const PluginName = "NamespaceAutoProvision"
    
    // Register registers a plugin
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 17:30:21 UTC 2020
    - 4.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go

    	"k8s.io/apimachinery/pkg/fields"
    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/wait"
    	corev1informers "k8s.io/client-go/informers/core/v1"
    	"k8s.io/client-go/kubernetes"
    	corev1listers "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/client-go/util/workqueue"
    	"k8s.io/klog/v2"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  6. plugin/pkg/admission/namespace/exists/admission.go

    	"k8s.io/apiserver/pkg/admission"
    	genericadmissioninitializer "k8s.io/apiserver/pkg/admission/initializer"
    	informers "k8s.io/client-go/informers"
    	"k8s.io/client-go/kubernetes"
    	corev1listers "k8s.io/client-go/listers/core/v1"
    	api "k8s.io/kubernetes/pkg/apis/core"
    )
    
    // PluginName indicates name of admission plugin.
    const PluginName = "NamespaceExists"
    
    // Register registers a plugin
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller_test.go

    import (
    	"context"
    	"encoding/json"
    	"k8s.io/apimachinery/pkg/api/equality"
    	"testing"
    
    	corev1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/client-go/kubernetes/fake"
    	corev1listers "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    )
    
    const (
    	defConfigMapName      = "extension-apiserver-authentication"
    	defConfigMapNamespace = "kube-system"
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 07 14:37:01 UTC 2022
    - 9.3K bytes
    - Viewed (0)
  8. plugin/pkg/admission/security/podsecurity/admission.go

    // Plugin holds state for and implements the admission plugin.
    type Plugin struct {
    	*admission.Handler
    
    	inspectedFeatureGates bool
    
    	client          kubernetes.Interface
    	namespaceLister corev1listers.NamespaceLister
    	podLister       corev1listers.PodLister
    
    	delegate *podsecurityadmission.Admission
    }
    
    var _ admission.ValidationInterface = &Plugin{}
    var _ genericadmissioninit.WantsExternalKubeInformerFactory = &Plugin{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 27 08:49:11 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/resource_access.go

    	"golang.org/x/sync/singleflight"
    	corev1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/labels"
    	"k8s.io/apiserver/pkg/storage"
    	"k8s.io/client-go/kubernetes"
    	corev1listers "k8s.io/client-go/listers/core/v1"
    	"k8s.io/utils/lru"
    )
    
    // QuotaAccessor abstracts the get/set logic from the rest of the Evaluator.  This could be a test stub, a straight passthrough,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 10 13:54:56 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go

    	"k8s.io/apimachinery/pkg/fields"
    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/wait"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	"k8s.io/client-go/kubernetes"
    	corev1listers "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/client-go/util/workqueue"
    	"k8s.io/klog/v2"
    )
    
    const (
    	authenticationRoleName = "extension-apiserver-authentication-reader"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top