- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetInformerFactory (0.41 sec)
-
pkg/kubelet/volume_host.go
return kvh.kubelet.subpather } func (kvh *kubeletVolumeHost) GetHostUtil() hostutil.HostUtils { return kvh.kubelet.hostutil } func (kvh *kubeletVolumeHost) GetInformerFactory() informers.SharedInformerFactory { return kvh.informerFactory } func (kvh *kubeletVolumeHost) CSIDriverLister() storagelisters.CSIDriverLister { return kvh.csiDriverLister }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/volume/plugins.go
// that will cause the Kubelet to post NotReady status with the error message provided SetKubeletError(err error) // GetInformerFactory returns the informer factory for CSIDriverLister GetInformerFactory() informers.SharedInformerFactory // CSIDriverLister returns the informer lister for the CSIDriver API Object CSIDriverLister() storagelistersv1.CSIDriverLister
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
} return csiNodeLister } func (f *fakeKubeletVolumeHost) SetKubeletError(err error) { f.mux.Lock() defer f.mux.Unlock() f.kubeletErr = err } func (f *fakeKubeletVolumeHost) GetInformerFactory() informers.SharedInformerFactory { return f.informerFactory } func (f *fakeKubeletVolumeHost) GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0)