kubernetes/pkg/volume/csi/csi_attacher.go

const globalMountInGlobalPath …

type csiAttacher …

var _ …

var _ …

var _ …

func (c *csiAttacher) Attach(spec *volume.Spec, nodeName types.NodeName) (string, error) { … }

// WaitForAttach waits for the attach operation to complete and returns the device path when it is done.
// But in this case, there should be no waiting. The device is found by the CSI driver later, in NodeStage / NodePublish calls.
// so it should just return device metadata, in this case it is VolumeAttachment name. If the target VolumeAttachment does not
// exist or is not attached, the function will return an error. And then the caller (kubelet) should retry it.
// We can get rid of watching it that serves no purpose. More details in https://issues.k8s.io/124398
func (c *csiAttacher) WaitForAttach(spec *volume.Spec, _ string, pod *v1.Pod, _ time.Duration) (string, error) { … }

func (c *csiAttacher) waitForVolumeAttachmentWithLister(spec *volume.Spec, volumeHandle, attachID string, timeout time.Duration) error { … }

func (c *csiAttacher) VolumesAreAttached(specs []*volume.Spec, nodeName types.NodeName) (map[*volume.Spec]bool, error) { … }

func (c *csiAttacher) GetDeviceMountPath(spec *volume.Spec) (string, error) { … }

func (c *csiAttacher) MountDevice(spec *volume.Spec, devicePath string, deviceMountPath string, deviceMounterArgs volume.DeviceMounterArgs) error { … }

var _ …

var _ …

func (c *csiAttacher) Detach(volumeName string, nodeName types.NodeName) error { … }

func (c *csiAttacher) waitForVolumeDetachmentWithLister(volumeHandle, attachID string, timeout time.Duration) error { … }

func (c *csiAttacher) waitForVolumeAttachDetachStatusWithLister(spec *volume.Spec, volumeHandle, attachID string, timeout time.Duration, verifyStatus func() (bool, error), operation string) error { … }

func (c *csiAttacher) UnmountDevice(deviceMountPath string) error { … }

// getAttachmentName returns csi-<sha256(volName,csiDriverName,NodeName)>
func getAttachmentName(volName, csiDriverName, nodeName string) string { … }

func makeDeviceMountPath(plugin *csiPlugin, spec *volume.Spec) (string, error) { … }

func verifyAttachmentStatus(attachment *storage.VolumeAttachment, volumeHandle string) (bool, error) { … }

func verifyDetachmentStatus(attachment *storage.VolumeAttachment, volumeHandle string) (bool, error) { … }