kubernetes/pkg/volume/portworx/portworx.go

const attachContextKey …

const attachHostKey …

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

type portworxVolumePlugin …

var _ …

var _ …

var _ …

var _ …

var _ …

const portworxVolumePluginName …

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

func (plugin *portworxVolumePlugin) IsMigratedToCSI() bool { … }

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

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

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

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

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

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

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

func (plugin *portworxVolumePlugin) newMounterInternal(spec *volume.Spec, podUID types.UID, manager portworxManager, mounter mount.Interface) (volume.Mounter, error) { … }

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

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

func (plugin *portworxVolumePlugin) NewDeleter(logger klog.Logger, spec *volume.Spec) (volume.Deleter, error) { … }

func (plugin *portworxVolumePlugin) newDeleterInternal(spec *volume.Spec, manager portworxManager) (volume.Deleter, error) { … }

func (plugin *portworxVolumePlugin) NewProvisioner(logger klog.Logger, options volume.VolumeOptions) (volume.Provisioner, error) { … }

func (plugin *portworxVolumePlugin) newProvisionerInternal(options volume.VolumeOptions, manager portworxManager) (volume.Provisioner, error) { … }

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

func (plugin *portworxVolumePlugin) ExpandVolumeDevice(
	spec *volume.Spec,
	newSize resource.Quantity,
	oldSize resource.Quantity) (resource.Quantity, error) { … }

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

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

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

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

type portworxManager …

type portworxVolume …

type portworxVolumeMounter …

var _ …

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

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

// SetUpAt attaches the disk and bind mounts to the volume path.
func (b *portworxVolumeMounter) SetUpAt(dir string, mounterArgs volume.MounterArgs) error { … }

func (pwx *portworxVolume) GetPath() string { … }

type portworxVolumeUnmounter …

var _ …

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

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

type portworxVolumeDeleter …

var _ …

func (d *portworxVolumeDeleter) GetPath() string { … }

func (d *portworxVolumeDeleter) Delete() error { … }

type portworxVolumeProvisioner …

var _ …

func (c *portworxVolumeProvisioner) Provision(selectedNode *v1.Node, allowedTopologies []v1.TopologySelectorTerm) (*v1.PersistentVolume, error) { … }