Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for storagelistersv1 (0.46 sec)

  1. pkg/volume/testing/volume_host.go

    	nodeLabels             map[string]string
    	nodeName               string
    	subpather              subpath.Interface
    	node                   *v1.Node
    	csiDriverLister        storagelistersv1.CSIDriverLister
    	volumeAttachmentLister storagelistersv1.VolumeAttachmentLister
    	informerFactory        informers.SharedInformerFactory
    	kubeletErr             error
    	mux                    sync.Mutex
    }
    
    var _ VolumeHost = &fakeVolumeHost{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  2. pkg/controller/volume/attachdetach/attach_detach_controller.go

    	nodesSynced kcache.InformerSynced
    
    	csiNodeLister storagelistersv1.CSINodeLister
    	csiNodeSynced kcache.InformerSynced
    
    	// csiDriverLister is the shared CSIDriver lister used to fetch and store
    	// CSIDriver objects from the API server. It is shared with other controllers
    	// and therefore the CSIDriver objects in its store should be treated as immutable.
    	csiDriverLister  storagelistersv1.CSIDriverLister
    	csiDriversSynced kcache.InformerSynced
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  3. pkg/volume/plugins.go

    	CSINodeLister() storagelistersv1.CSINodeLister
    
    	// CSIDriverLister returns the informer lister for the CSIDriver API Object
    	CSIDriverLister() storagelistersv1.CSIDriverLister
    
    	// VolumeAttachmentLister returns the informer lister for the VolumeAttachment API Object
    	VolumeAttachmentLister() storagelistersv1.VolumeAttachmentLister
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:13:15 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  4. pkg/kubelet/volume_host.go

    	v1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/types"
    	"k8s.io/apimachinery/pkg/util/wait"
    	"k8s.io/client-go/informers"
    	clientset "k8s.io/client-go/kubernetes"
    	storagelisters "k8s.io/client-go/listers/storage/v1"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/client-go/tools/record"
    	"k8s.io/kubernetes/pkg/kubelet/clustertrustbundle"
    	"k8s.io/kubernetes/pkg/kubelet/configmap"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 10K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go

    	filter         VolumeFilter
    	volumeLimitKey v1.ResourceName
    	maxVolumeFunc  func(node *v1.Node) int
    	csiNodeLister  storagelisters.CSINodeLister
    	pvLister       corelisters.PersistentVolumeLister
    	pvcLister      corelisters.PersistentVolumeClaimLister
    	scLister       storagelisters.StorageClassLister
    
    	// The string below is generated randomly during the struct's initialization.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 30 23:00:56 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  6. pkg/scheduler/testing/framework/fake_listers.go

    	"k8s.io/apimachinery/pkg/api/errors"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/labels"
    	appslisters "k8s.io/client-go/listers/apps/v1"
    	corelisters "k8s.io/client-go/listers/core/v1"
    	storagelisters "k8s.io/client-go/listers/storage/v1"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    )
    
    var _ corelisters.ServiceLister = &ServiceLister{}
    
    // ServiceLister implements ServiceLister on []v1.Service for test purposes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 20 10:14:08 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    }
    
    // CSILimits is a plugin that checks node volume limits.
    type CSILimits struct {
    	csiNodeLister storagelisters.CSINodeLister
    	pvLister      corelisters.PersistentVolumeLister
    	pvcLister     corelisters.PersistentVolumeClaimLister
    	scLister      storagelisters.StorageClassLister
    
    	randomVolumeIDPrefix string
    
    	translator InTreeToCSITranslator
    }
    
    var _ framework.PreFilterPlugin = &CSILimits{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/volumezone/volume_zone.go

    	storage "k8s.io/api/storage/v1"
    	apierrors "k8s.io/apimachinery/pkg/api/errors"
    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apimachinery/pkg/util/sets"
    	corelisters "k8s.io/client-go/listers/core/v1"
    	storagelisters "k8s.io/client-go/listers/storage/v1"
    	volumehelpers "k8s.io/cloud-provider/volume/helpers"
    	storagehelpers "k8s.io/component-helpers/storage/volume"
    	"k8s.io/klog/v2"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/volumebinding/binder.go

    	unboundVolumesDelayBinding map[string][]*v1.PersistentVolume
    }
    
    type volumeBinder struct {
    	kubeClient clientset.Interface
    
    	classLister   storagelisters.StorageClassLister
    	podLister     corelisters.PodLister
    	nodeLister    corelisters.NodeLister
    	csiNodeLister storagelisters.CSINodeLister
    
    	pvcCache *PVCAssumeCache
    	pvCache  *PVAssumeCache
    
    	// Amount of time to wait for the bind operation to succeed
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  10. pkg/volume/csi/csi_plugin.go

    )
    
    type csiPlugin struct {
    	host                      volume.VolumeHost
    	csiDriverLister           storagelisters.CSIDriverLister
    	serviceAccountTokenGetter func(namespace, name string, tr *authenticationv1.TokenRequest) (*authenticationv1.TokenRequest, error)
    	volumeAttachmentLister    storagelisters.VolumeAttachmentLister
    }
    
    // ProbeVolumePlugins returns implemented plugins
    func ProbeVolumePlugins() []volume.VolumePlugin {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
Back to top