kubernetes/pkg/volume/fc/fc.go

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

type fcPlugin …

var _ …

var _ …

var _ …

const fcPluginName …

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

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

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

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

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

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

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

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

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

func (plugin *fcPlugin) newMounterInternal(spec *volume.Spec, podUID types.UID, manager diskManager, mounter mount.Interface, exec utilexec.Interface) (volume.Mounter, error) { … }

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

func (plugin *fcPlugin) newBlockVolumeMapperInternal(spec *volume.Spec, podUID types.UID, manager diskManager, mounter mount.Interface, exec utilexec.Interface) (volume.BlockVolumeMapper, error) { … }

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

func (plugin *fcPlugin) newUnmounterInternal(volName string, podUID types.UID, manager diskManager, mounter mount.Interface, exec utilexec.Interface) (volume.Unmounter, error) { … }

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

func (plugin *fcPlugin) newUnmapperInternal(volName string, podUID types.UID, manager diskManager, exec utilexec.Interface) (volume.BlockVolumeUnmapper, error) { … }

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

// ConstructBlockVolumeSpec creates a new volume.Spec with following steps.
//   - Searches a file whose name is {pod uuid} under volume plugin directory.
//   - If a file is found, then retrieves volumePluginDependentPath from globalMapPathUUID.
//   - Once volumePluginDependentPath is obtained, store volume information to VolumeSource
//
// examples:
//
//	mapPath: pods/{podUid}/{DefaultKubeletVolumeDevicesDirName}/{escapeQualifiedPluginName}/{volumeName}
//	globalMapPathUUID : plugins/kubernetes.io/{PluginName}/{DefaultKubeletVolumeDevicesDirName}/{volumePluginDependentPath}/{pod uuid}
func (plugin *fcPlugin) ConstructBlockVolumeSpec(podUID types.UID, volumeName, mapPath string) (*volume.Spec, error) { … }

type fcDisk …

func (fc *fcDisk) GetPath() string { … }

func (fc *fcDisk) fcGlobalMapPath(spec *volume.Spec) (string, error) { … }

func (fc *fcDisk) fcPodDeviceMapPath() (string, string) { … }

type fcDiskMounter …

var _ …

func (b *fcDiskMounter) GetAttributes() volume.Attributes { … }

func (b *fcDiskMounter) SetUp(mounterArgs volume.MounterArgs) error { … }

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

type fcDiskUnmounter …

var _ …

// Unmounts the bind mount, and detaches the disk only if the disk
// resource was the last reference to that disk on the kubelet.
func (c *fcDiskUnmounter) TearDown() error { … }

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

type fcDiskMapper …

var _ …

type fcDiskUnmapper …

var _ …

var _ …

func (c *fcDiskUnmapper) TearDownDevice(mapPath, devicePath string) error { … }

func (c *fcDiskUnmapper) UnmapPodDevice() error { … }

// GetGlobalMapPath returns global map path and error
// path: plugins/kubernetes.io/{PluginName}/volumeDevices/{WWID}/{podUid}
func (fc *fcDisk) GetGlobalMapPath(spec *volume.Spec) (string, error) { … }

// GetPodDeviceMapPath returns pod device map path and volume name
// path: pods/{podUid}/volumeDevices/kubernetes.io~fc
// volumeName: pv0001
func (fc *fcDisk) GetPodDeviceMapPath() (string, string) { … }

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

func createPersistentVolumeFromFCVolumeSource(volumeName string, fc v1.FCVolumeSource) *v1.PersistentVolume { … }

func getWwnsLunWwids(fc *v1.FCVolumeSource) ([]string, string, []string, error) { … }