Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetInformerFactory (0.51 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top