kubernetes/pkg/volume/nfs/nfs.go

func getPath(uid types.UID, volName string, host volume.VolumeHost) string { … }

// ProbeVolumePlugins is the primary entrypoint for volume plugins.
// This is the primary entrypoint for volume plugins.
// The volumeConfig arg provides the ability to configure recycler behavior.  It is implemented as a pointer to allow nils.
// The nfsPlugin is used to store the volumeConfig and give it, when needed, to the func that creates NFS Recyclers.
// Tests that exercise recycling should not use this func but instead use ProbeRecyclablePlugins() to override default behavior.
func ProbeVolumePlugins(volumeConfig volume.VolumeConfig) []volume.VolumePlugin { … }

type nfsPlugin …

var _ …

var _ …

var _ …

const nfsPluginName …

const unMountTimeout …

func (plugin *nfsPlugin) Init(host volume.VolumeHost) error { … }

func (plugin *nfsPlugin) GetPluginName() string { … }

func (plugin *nfsPlugin) GetVolumeName(spec *volume.Spec) (string, error) { … }

func (plugin *nfsPlugin) CanSupport(spec *volume.Spec) bool { … }

func (plugin *nfsPlugin) RequiresRemount(spec *volume.Spec) bool { … }

func (plugin *nfsPlugin) SupportsMountOption() bool { … }

func (plugin *nfsPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) { … }

func (plugin *nfsPlugin) GetAccessModes() []v1.PersistentVolumeAccessMode { … }

func (plugin *nfsPlugin) NewMounter(spec *volume.Spec, pod *v1.Pod) (volume.Mounter, error) { … }

func (plugin *nfsPlugin) newMounterInternal(spec *volume.Spec, pod *v1.Pod, mounter mount.Interface) (volume.Mounter, error) { … }

func (plugin *nfsPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { … }

func (plugin *nfsPlugin) newUnmounterInternal(volName string, podUID types.UID, mounter mount.Interface) (volume.Unmounter, error) { … }

// Recycle recycles/scrubs clean an NFS volume.
// Recycle blocks until the pod has completed or any error occurs.
func (plugin *nfsPlugin) Recycle(pvName string, spec *volume.Spec, eventRecorder recyclerclient.RecycleEventRecorder) error { … }

func (plugin *nfsPlugin) ConstructVolumeSpec(volumeName, mountPath string) (volume.ReconstructedVolume, error) { … }

type nfs …

func (nfsVolume *nfs) GetPath() string { … }

type nfsMounter …

var _ …

func (nfsMounter *nfsMounter) GetAttributes() volume.Attributes { … }

// SetUp attaches the disk and bind mounts to the volume path.
func (nfsMounter *nfsMounter) SetUp(mounterArgs volume.MounterArgs) error { … }

func (nfsMounter *nfsMounter) SetUpAt(dir string, mounterArgs volume.MounterArgs) error { … }

var _ …

type nfsUnmounter …

func (c *nfsUnmounter) TearDown() error { … }

func (c *nfsUnmounter) TearDownAt(dir string) error { … }

func getVolumeSource(spec *volume.Spec) (*v1.NFSVolumeSource, bool, error) { … }

func getServerFromSource(source *v1.NFSVolumeSource) string { … }