Versions in this module Expand all Collapse all v0 v0.1.0 May 16, 2018 Changes in this version + const ControllerManagedAttachAnnotation + const GB + const GIB + const KeepTerminatedPodVolumesAnnotation + const VolumeDynamicallyCreatedByKey + const VolumeGidAnnotationKey + func AccessModesContainedInAll(indexedModes []v1.PersistentVolumeAccessMode, ...) bool + func AccessModesContains(modes []v1.PersistentVolumeAccessMode, mode v1.PersistentVolumeAccessMode) bool + func CalculateTimeoutForVolume(minimumTimeout, timeoutIncrement int, pv *v1.PersistentVolume) int64 + func CheckVolumeModeFilesystem(volumeSpec *volume.Spec) (bool, error) + func ChooseZoneForVolume(zones sets.String, pvcName string) string + func ChooseZonesForVolume(zones sets.String, pvcName string, numZones uint32) sets.String + func GenerateVolumeName(clusterName, pvName string, maxLength int) string + func GetClassForVolume(kubeClient clientset.Interface, pv *v1.PersistentVolume) (*storage.StorageClass, error) + func GetPath(mounter volume.Mounter) (string, error) + func GetPersistentVolumeClaimVolumeMode(claim *v1.PersistentVolumeClaim) (v1.PersistentVolumeMode, error) + func GetSecretForPV(secretNamespace, secretName, volumePluginName string, ...) (map[string]string, error) + func GetSecretForPod(pod *v1.Pod, secretName string, kubeClient clientset.Interface) (map[string]string, error) + func GetUniquePodName(pod *v1.Pod) types.UniquePodName + func GetUniqueVolumeName(pluginName, volumeName string) v1.UniqueVolumeName + func GetUniqueVolumeNameForNonAttachableVolume(podName types.UniquePodName, volumePlugin volume.VolumePlugin, ...) v1.UniqueVolumeName + func GetUniqueVolumeNameFromSpec(volumePlugin volume.VolumePlugin, volumeSpec *volume.Spec) (v1.UniqueVolumeName, error) + func GetVolumeMode(volumeSpec *volume.Spec) (v1.PersistentVolumeMode, error) + func GetWindowsPath(path string) string + func IsPodTerminated(pod *v1.Pod, podStatus v1.PodStatus) bool + func IsReady(dir string) bool + func JoinMountOptions(userOptions []string, systemOptions []string) []string + func LabelZonesToSet(labelZonesValue string) (sets.String, error) + func LoadPodFromFile(filePath string) (*v1.Pod, error) + func MountOptionFromSpec(spec *volume.Spec, options ...string) []string + func NewDanglingError(msg string, node k8stypes.NodeName, devicePath string) error + func NewSafeFormatAndMountFromHost(pluginName string, host volume.VolumeHost) *mount.SafeFormatAndMount + func PathExists(path string) (bool, error) + func RoundUpSize(volumeSizeBytes int64, allocationUnitBytes int64) int64 + func RoundUpToGB(size resource.Quantity) int64 + func RoundUpToGiB(size resource.Quantity) int64 + func SetReady(dir string) + func SplitUniqueName(uniqueName v1.UniqueVolumeName) (string, string, error) + func UnmountMountPoint(mountPath string, mounter mount.Interface, extensiveMountPointCheck bool) error + func UnmountPath(mountPath string, mounter mount.Interface) error + func UnmountViaEmptyDir(dir string, host volume.VolumeHost, volName string, volSpec volume.Spec, ...) error + func ValidateZone(zone string) error + func ZonesSetToLabelValue(strSet sets.String) string + func ZonesToSet(zonesString string) (sets.String, error) + type DanglingAttachError struct + CurrentNode k8stypes.NodeName + DevicePath string + func (err *DanglingAttachError) Error() string