kubernetes/pkg/volume/testing/volume_host.go

type FakeVolumeHost …

type fakeVolumeHost …

var _ …

var _ …

func NewFakeVolumeHost(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin) FakeVolumeHost { … }

func NewFakeVolumeHostWithCloudProvider(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin) FakeVolumeHost { … }

func NewFakeVolumeHostWithCSINodeName(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin, nodeName string, driverLister storagelistersv1.CSIDriverLister, volumeAttachLister storagelistersv1.VolumeAttachmentLister) FakeVolumeHost { … }

func newFakeVolumeHost(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin, pathToTypeMap map[string]hostutil.FileType, nodeName string, driverLister storagelistersv1.CSIDriverLister, volumeAttachLister storagelistersv1.VolumeAttachmentLister) FakeVolumeHost { … }

func (f *fakeVolumeHost) GetPluginDir(podUID string) string { … }

func (f *fakeVolumeHost) GetVolumeDevicePluginDir(pluginName string) string { … }

func (f *fakeVolumeHost) GetPodsDir() string { … }

func (f *fakeVolumeHost) GetPodVolumeDir(podUID types.UID, pluginName, volumeName string) string { … }

func (f *fakeVolumeHost) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string { … }

func (f *fakeVolumeHost) GetPodPluginDir(podUID types.UID, pluginName string) string { … }

func (f *fakeVolumeHost) GetKubeClient() clientset.Interface { … }

func (f *fakeVolumeHost) GetMounter(pluginName string) mount.Interface { … }

func (f *fakeVolumeHost) GetSubpather() subpath.Interface { … }

func (f *fakeVolumeHost) GetPluginMgr() *VolumePluginMgr { … }

func (f *fakeVolumeHost) GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) { … }

func (f *fakeVolumeHost) NewWrapperMounter(volName string, spec Spec, pod *v1.Pod) (Mounter, error) { … }

func (f *fakeVolumeHost) NewWrapperUnmounter(volName string, spec Spec, podUID types.UID) (Unmounter, error) { … }

// Returns the hostname of the host kubelet is running on
func (f *fakeVolumeHost) GetHostName() string { … }

// Returns host IP or nil in the case of error.
func (f *fakeVolumeHost) GetHostIP() (net.IP, error) { … }

func (f *fakeVolumeHost) GetNodeAllocatable() (v1.ResourceList, error) { … }

func (f *fakeVolumeHost) GetSecretFunc() func(namespace, name string) (*v1.Secret, error) { … }

func (f *fakeVolumeHost) GetExec(pluginName string) exec.Interface { … }

func (f *fakeVolumeHost) GetConfigMapFunc() func(namespace, name string) (*v1.ConfigMap, error) { … }

func (f *fakeVolumeHost) GetServiceAccountTokenFunc() func(string, string, *authenticationv1.TokenRequest) (*authenticationv1.TokenRequest, error) { … }

func (f *fakeVolumeHost) DeleteServiceAccountTokenFunc() func(types.UID) { … }

func (f *fakeVolumeHost) GetNodeLabels() (map[string]string, error) { … }

func (f *fakeVolumeHost) GetNodeName() types.NodeName { … }

func (f *fakeVolumeHost) GetEventRecorder() record.EventRecorder { … }

func (f *fakeVolumeHost) ScriptCommands(scripts []CommandScript) { … }

func (f *fakeVolumeHost) WaitForKubeletErrNil() error { … }

type fakeAttachDetachVolumeHost …

var _ …

var _ …

func NewFakeAttachDetachVolumeHostWithCSINodeName(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin, nodeName string, driverLister storagelistersv1.CSIDriverLister, volumeAttachLister storagelistersv1.VolumeAttachmentLister) FakeVolumeHost { … }

func newFakeAttachDetachVolumeHost(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin, pathToTypeMap map[string]hostutil.FileType, nodeName string, driverLister storagelistersv1.CSIDriverLister, volumeAttachLister storagelistersv1.VolumeAttachmentLister) FakeVolumeHost { … }

func (f *fakeAttachDetachVolumeHost) CSINodeLister() storagelistersv1.CSINodeLister { … }

func enableMigrationOnNode(csiNode *storagev1.CSINode, pluginName string) { … }

func (f *fakeAttachDetachVolumeHost) CSIDriverLister() storagelistersv1.CSIDriverLister { … }

func (f *fakeAttachDetachVolumeHost) VolumeAttachmentLister() storagelistersv1.VolumeAttachmentLister { … }

func (f *fakeAttachDetachVolumeHost) IsAttachDetachController() bool { … }

type fakeKubeletVolumeHost …

var _ …

var _ …

func NewFakeKubeletVolumeHost(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin) *fakeKubeletVolumeHost { … }

func NewFakeKubeletVolumeHostWithCSINodeName(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin, nodeName string, driverLister storagelistersv1.CSIDriverLister, volumeAttachLister storagelistersv1.VolumeAttachmentLister) *fakeKubeletVolumeHost { … }

func NewFakeKubeletVolumeHostWithMounterFSType(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin, pathToTypeMap map[string]hostutil.FileType) *fakeKubeletVolumeHost { … }

func newFakeKubeletVolumeHost(t *testing.T, rootDir string, kubeClient clientset.Interface, plugins []VolumePlugin, pathToTypeMap map[string]hostutil.FileType, nodeName string, driverLister storagelistersv1.CSIDriverLister, volumeAttachLister storagelistersv1.VolumeAttachmentLister) *fakeKubeletVolumeHost { … }

func (f *fakeKubeletVolumeHost) WithNode(node *v1.Node) *fakeKubeletVolumeHost { … }

type CSINodeLister …

// Get returns a fake CSINode object.
func (n CSINodeLister) Get(name string) (*storagev1.CSINode, error) { … }

// List lists all CSINodes in the indexer.
func (n CSINodeLister) List(selector labels.Selector) (ret []*storagev1.CSINode, err error) { … }

func getFakeCSINodeLister(csiNode *storagev1.CSINode) CSINodeLister { … }

func (f *fakeKubeletVolumeHost) SetKubeletError(err error) { … }

func (f *fakeKubeletVolumeHost) GetInformerFactory() informers.SharedInformerFactory { … }

func (f *fakeKubeletVolumeHost) GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) { … }

func (f *fakeKubeletVolumeHost) CSIDriverLister() storagelistersv1.CSIDriverLister { … }

func (f *fakeKubeletVolumeHost) CSIDriversSynced() cache.InformerSynced { … }

func (f *fakeKubeletVolumeHost) WaitForCacheSync() error { … }

func (f *fakeKubeletVolumeHost) GetHostUtil() hostutil.HostUtils { … }

func (f *fakeKubeletVolumeHost) GetTrustAnchorsByName(name string, allowMissing bool) ([]byte, error) { … }

// Note: we do none of the deduplication and sorting that the real deal should do.
func (f *fakeKubeletVolumeHost) GetTrustAnchorsBySigner(signerName string, labelSelector *metav1.LabelSelector, allowMissing bool) ([]byte, error) { … }