kubernetes/test/e2e/storage/detach_mounted.go

var durationForStuckMount …

var _ …

func getUniqueVolumeName(pod *v1.Pod, driverName string) string { … }

func waitForVolumesNotInUse(ctx context.Context, client clientset.Interface, nodeName, volumeName string) error { … }

func waitForVolumesAttached(ctx context.Context, client clientset.Interface, nodeName, volumeName string) error { … }

func waitForVolumesInUse(ctx context.Context, client clientset.Interface, nodeName, volumeName string) error { … }

func getFlexVolumePod(volumeSource v1.VolumeSource, nodeName string) *v1.Pod { … }