Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + const AzureVolumeLimitKey + const CSIAttachLimitPrefix + const CinderVolumeLimitKey + const ControllerManagedAttachAnnotation + const DefaultMaxCinderVolumes + const DefaultMaxEBSNitroVolumeLimit + const DefaultMaxEBSVolumes + const EBSNitroLimitRegex + const EBSVolumeLimitKey + const GCEVolumeLimitKey + const KeepTerminatedPodVolumesAnnotation + const MountsInGlobalPDPath + 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 ClaimToClaimKey(claim *v1.PersistentVolumeClaim) string + func GenerateVolumeName(clusterName, pvName string, maxLength int) string + func GenericResizeFS(host volume.VolumeHost, pluginName, devicePath, deviceMountPath string) (bool, error) + func GetCSIAttachLimitKey(driverName string) string + func GetClassForVolume(kubeClient clientset.Interface, pv *v1.PersistentVolume) (*storage.StorageClass, error) + func GetFullQualifiedPluginNameForVolume(pluginName string, spec *volume.Spec) string + func GetPath(mounter volume.Mounter) (string, error) + func GetPersistentVolumeClaimQualifiedName(claim *v1.PersistentVolumeClaim) string + func GetPluginMountDir(host volume.VolumeHost, name string) string + func GetPodVolumeNames(pod *v1.Pod) (mounts sets.String, devices sets.String) + 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 GetUniqueVolumeNameFromSpec(volumePlugin volume.VolumePlugin, volumeSpec *volume.Spec) (v1.UniqueVolumeName, error) + func GetUniqueVolumeNameFromSpecWithPod(podName types.UniquePodName, volumePlugin volume.VolumePlugin, ...) v1.UniqueVolumeName + func GetVolumeMode(volumeSpec *volume.Spec) (v1.PersistentVolumeMode, error) + func GetWindowsPath(path string) string + func HasMountRefs(mountPath string, mountRefs []string) bool + func IsLocalEphemeralVolume(volume v1.Volume) 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 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, newSize resource.Quantity, ...) error + func MarkForFSResize(pvc *v1.PersistentVolumeClaim, kubeClient clientset.Interface) error + func MarkResizeFinished(pvc *v1.PersistentVolumeClaim, newSize resource.Quantity, ...) error + func MarkResizeInProgressWithResizer(pvc *v1.PersistentVolumeClaim, resizerName string, ...) (*v1.PersistentVolumeClaim, error) + func MergeResizeConditionOnPVC(pvc *v1.PersistentVolumeClaim, ...) *v1.PersistentVolumeClaim + func MountOptionFromSpec(spec *volume.Spec, options ...string) []string + 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 RecordOperationLatencyMetric(plugin, operationName string, secondsTaken float64) + func SetClaimResizer(pvc *v1.PersistentVolumeClaim, resizerName string, ...) (*v1.PersistentVolumeClaim, error) + func SetReady(dir string) + func SplitUniqueName(uniqueName v1.UniqueVolumeName) (string, string, error) + func UnmountViaEmptyDir(dir string, host volume.VolumeHost, volName string, volSpec volume.Spec, ...) error + func UpdatePVSize(pv *v1.PersistentVolume, newSize resource.Quantity, ...) error + func WriteVolumeCache(deviceMountPath string, exec mount.Exec) error + type AtomicWriter struct + func NewAtomicWriter(targetDir string, logContext string) (*AtomicWriter, error) + func (w *AtomicWriter) Write(payload map[string]FileProjection) error + 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