kubernetes/pkg/volume/local/local.go

const defaultFSType …

// ProbeVolumePlugins is the primary entrypoint for volume plugins.
func ProbeVolumePlugins() []volume.VolumePlugin { … }

type localVolumePlugin …

var _ …

var _ …

var _ …

var _ …

const localVolumePluginName …

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

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

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

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

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

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

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

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

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

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

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

func (plugin *localVolumePlugin) NewBlockVolumeMapper(spec *volume.Spec, pod *v1.Pod) (volume.BlockVolumeMapper, error) { … }

func (plugin *localVolumePlugin) NewBlockVolumeUnmapper(volName string,
	podUID types.UID) (volume.BlockVolumeUnmapper, error) { … }

// TODO: check if no path and no topology constraints are ok
func (plugin *localVolumePlugin) ConstructVolumeSpec(volumeName, mountPath string) (volume.ReconstructedVolume, error) { … }

func (plugin *localVolumePlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName,
	mapPath string) (*volume.Spec, error) { … }

func (plugin *localVolumePlugin) generateBlockDeviceBaseGlobalPath() string { … }

func (plugin *localVolumePlugin) getGlobalLocalPath(spec *volume.Spec) (string, error) { … }

var _ …

type deviceMounter …

var _ …

func (plugin *localVolumePlugin) CanDeviceMount(spec *volume.Spec) (bool, error) { … }

func (plugin *localVolumePlugin) NewDeviceMounter() (volume.DeviceMounter, error) { … }

func (dm *deviceMounter) mountLocalBlockDevice(spec *volume.Spec, devicePath string, deviceMountPath string) error { … }

func (dm *deviceMounter) MountDevice(spec *volume.Spec, devicePath string, deviceMountPath string, _ volume.DeviceMounterArgs) error { … }

func (plugin *localVolumePlugin) RequiresFSResize() bool { … }

func (plugin *localVolumePlugin) NodeExpand(resizeOptions volume.NodeResizeOptions) (bool, error) { … }

func getVolumeSourceFSType(spec *volume.Spec) (string, error) { … }

func getVolumeSourceReadOnly(spec *volume.Spec) (bool, error) { … }

func (dm *deviceMounter) GetDeviceMountPath(spec *volume.Spec) (string, error) { … }

func (plugin *localVolumePlugin) NewDeviceUnmounter() (volume.DeviceUnmounter, error) { … }

func (plugin *localVolumePlugin) GetDeviceMountRefs(deviceMountPath string) ([]string, error) { … }

var _ …

func (dm *deviceMounter) UnmountDevice(deviceMountPath string) error { … }

type localVolume …

func (l *localVolume) GetPath() string { … }

type localVolumeMounter …

var _ …

func (m *localVolumeMounter) GetAttributes() volume.Attributes { … }

// SetUp bind mounts the directory to the volume path
func (m *localVolumeMounter) SetUp(mounterArgs volume.MounterArgs) error { … }

// SetUpAt bind mounts the directory to the volume path and sets up volume ownership
func (m *localVolumeMounter) SetUpAt(dir string, mounterArgs volume.MounterArgs) error { … }

// filterPodMounts only returns mount paths inside the kubelet pod directory
func (m *localVolumeMounter) filterPodMounts(refs []string) []string { … }

type localVolumeUnmounter …

var _ …

// TearDown unmounts the bind mount
func (u *localVolumeUnmounter) TearDown() error { … }

// TearDownAt unmounts the bind mount
func (u *localVolumeUnmounter) TearDownAt(dir string) error { … }

type localVolumeMapper …

var _ …

var _ …

// SetUpDevice prepares the volume to the node by the plugin specific way.
func (m *localVolumeMapper) SetUpDevice() (string, error) { … }

// MapPodDevice provides physical device path for the local PV.
func (m *localVolumeMapper) MapPodDevice() (string, error) { … }

// GetStagingPath returns
func (m *localVolumeMapper) GetStagingPath() string { … }

// SupportsMetrics returns true for SupportsMetrics as it initializes the
// MetricsProvider.
func (m *localVolumeMapper) SupportsMetrics() bool { … }

type localVolumeUnmapper …

var _ …

// GetGlobalMapPath returns global map path and error.
// path: plugins/kubernetes.io/kubernetes.io/local-volume/volumeDevices/{volumeName}
func (l *localVolume) GetGlobalMapPath(spec *volume.Spec) (string, error) { … }

// GetPodDeviceMapPath returns pod device map path and volume name.
// path: pods/{podUid}/volumeDevices/kubernetes.io~local-volume
// volName: local-pv-ff0d6d4
func (l *localVolume) GetPodDeviceMapPath() (string, string) { … }