Versions in this module Expand all Collapse all v1 v1.1.0 Mar 14, 2022 v1.0.0 Jun 3, 2021 v0 v0.9.0 Jun 23, 2020 Changes in this version + const AzureVolumeLimitKey + const CSIAttachLimitPrefix + const ControllerManagedAttachAnnotation + const DefaultMaxEBSNitroVolumeLimit + const DefaultMaxEBSVolumes + const EBSNitroLimitRegex + const EBSVolumeLimitKey + const GB + const GCEVolumeLimitKey + const GIB + const KeepTerminatedPodVolumesAnnotation + const PVCProtectionFinalizer + const PVProtectionFinalizer + const ResourceNameLengthLimit + 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 CheckNodeAffinity(pv *v1.PersistentVolume, nodeLabels map[string]string) error + func CheckPersistentVolumeClaimModeBlock(pvc *v1.PersistentVolumeClaim) bool + 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 ClaimToClaimKey(claim *v1.PersistentVolumeClaim) string + func GenerateVolumeName(clusterName, pvName string, maxLength int) string + func GetCSIAttachLimitKey(driverName string) string + func GetClassForVolume(kubeClient clientset.Interface, pv *v1.PersistentVolume) (*storage.StorageClass, error) + func GetPath(mounter volume.Mounter) (string, error) + func GetPersistentVolumeClaimQualifiedName(claim *v1.PersistentVolumeClaim) string + 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 IsCorruptedMnt(err error) bool + func IsPodTerminated(pod *v1.Pod, podStatus v1.PodStatus) bool + func IsReady(dir string) bool + func IsWindowsLocalPath(goos, path string) bool + func IsWindowsUNCPath(goos, path string) bool + func JoinMountOptions(userOptions []string, systemOptions []string) []string + func LabelZonesToList(labelZonesValue string) ([]string, error) + func LabelZonesToSet(labelZonesValue string) (sets.String, error) + func LoadPodFromFile(filePath string) (*v1.Pod, error) + func MakeAbsolutePath(goos, path string) string + func MakeNestedMountpoints(name, baseDir string, pod v1.Pod) error + func MapBlockVolume(devicePath, globalMapPath, podVolumeMapPath, volumeMapName string, ...) error + func MarkFSResizeFinished(pvc *v1.PersistentVolumeClaim, capacity v1.ResourceList, ...) error + func MergeResizeConditionOnPVC(pvc *v1.PersistentVolumeClaim, ...) *v1.PersistentVolumeClaim + 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 OperationCompleteHook(plugin, operationName string) func(*error) + func PatchPVCStatus(oldPVC *v1.PersistentVolumeClaim, newPVC *v1.PersistentVolumeClaim, ...) (*v1.PersistentVolumeClaim, error) + func PathExists(path string) (bool, error) + func RoundUpSize(volumeSizeBytes int64, allocationUnitBytes int64) int64 + func RoundUpSizeInt(volumeSizeBytes int64, allocationUnitBytes int64) (int, error) + func RoundUpToGB(size resource.Quantity) int64 + func RoundUpToGBInt(size resource.Quantity) (int, error) + func RoundUpToGiB(size resource.Quantity) int64 + func RoundUpToGiBInt(size resource.Quantity) (int, error) + func SelectZoneForVolume(zoneParameterPresent, zonesParameterPresent bool, zoneParameter string, ...) (string, error) + func SelectZonesForVolume(zoneParameterPresent, zonesParameterPresent bool, zoneParameter string, ...) (sets.String, error) + 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 ZonesFromAllowedTopologies(allowedTopologies []v1.TopologySelectorTerm) (sets.String, error) + func ZonesSetToLabelValue(strSet sets.String) string + func ZonesToSet(zonesString string) (sets.String, error) + type AtomicWriter struct + func NewAtomicWriter(targetDir string, logContext string) (*AtomicWriter, error) + func (w *AtomicWriter) Write(payload map[string]FileProjection) error + type DanglingAttachError struct + CurrentNode k8stypes.NodeName + DevicePath string + func (err *DanglingAttachError) Error() string + type DeviceUtil interface + FindDevicesForISCSILun func(targetIqn string, lun int) ([]string, error) + FindMultipathDeviceForDevice func(disk string) string + FindSlaveDevicesOnMultipath func(disk string) []string + GetISCSIPortalHostMapForTarget func(targetIqn string) (map[string]int, error) + func NewDeviceHandler(io IoUtil) DeviceUtil + type FileProjection struct + Data []byte + Mode int32 + type IoUtil interface + EvalSymlinks func(path string) (string, error) + Lstat func(name string) (os.FileInfo, error) + ReadDir func(dirname string) ([]os.FileInfo, error) + ReadFile func(filename string) ([]byte, error) + func NewIOHandler() IoUtil + type VolumeZoneConfig struct + ReplicaZoneFromNode string + ReplicaZoneFromNodePresent bool + Zone string + ZonePresent bool + Zones string + ZonesPresent bool