Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + type ActualStateOfWorldAttacherUpdater interface + AddVolumeToReportAsAttached func(volumeName v1.UniqueVolumeName, nodeName types.NodeName) + MarkVolumeAsAttached func(volumeName v1.UniqueVolumeName, volumeSpec *volume.Spec, ...) error + MarkVolumeAsDetached func(volumeName v1.UniqueVolumeName, nodeName types.NodeName) + MarkVolumeAsUncertain func(volumeName v1.UniqueVolumeName, volumeSpec *volume.Spec, ...) error + RemoveVolumeFromReportAsAttached func(volumeName v1.UniqueVolumeName, nodeName types.NodeName) error + type ActualStateOfWorldMounterUpdater interface + MarkDeviceAsMounted func(volumeName v1.UniqueVolumeName, devicePath, deviceMountPath string) error + MarkDeviceAsUnmounted func(volumeName v1.UniqueVolumeName) error + MarkVolumeAsMounted func(podName volumetypes.UniquePodName, podUID types.UID, ...) error + MarkVolumeAsResized func(podName volumetypes.UniquePodName, volumeName v1.UniqueVolumeName) error + MarkVolumeAsUnmounted func(podName volumetypes.UniquePodName, volumeName v1.UniqueVolumeName) error + type AttachedVolume struct + DeviceMountPath string + DevicePath string + NodeName types.NodeName + PluginIsAttachable bool + PluginName string + VolumeName v1.UniqueVolumeName + VolumeSpec *volume.Spec + func (volume *AttachedVolume) GenerateError(prefixMsg string, err error) (simpleErr, detailedErr error) + func (volume *AttachedVolume) GenerateErrorDetailed(prefixMsg string, err error) (detailedErr error) + func (volume *AttachedVolume) GenerateMsg(prefixMsg, suffixMsg string) (simpleMsg, detailedMsg string) + func (volume *AttachedVolume) GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string) + type MountedVolume struct + BlockVolumeMapper volume.BlockVolumeMapper + DeviceMountPath string + InnerVolumeSpecName string + Mounter volume.Mounter + OuterVolumeSpecName string + PluginName string + PodName volumetypes.UniquePodName + PodUID types.UID + VolumeGidValue string + VolumeName v1.UniqueVolumeName + VolumeSpec *volume.Spec + func (volume *MountedVolume) GenerateError(prefixMsg string, err error) (simpleErr, detailedErr error) + func (volume *MountedVolume) GenerateErrorDetailed(prefixMsg string, err error) (detailedErr error) + func (volume *MountedVolume) GenerateMsg(prefixMsg, suffixMsg string) (simpleMsg, detailedMsg string) + func (volume *MountedVolume) GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string) + type OperationExecutor interface + AttachVolume func(volumeToAttach VolumeToAttach, ...) error + CheckVolumeExistenceOperation func(volumeSpec *volume.Spec, mountPath, volumeName string, mounter mount.Interface, ...) (bool, error) + DetachVolume func(volumeToDetach AttachedVolume, verifySafeToDetach bool, ...) error + ExpandInUseVolume func(volumeToMount VolumeToMount, ...) error + IsOperationPending func(volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName) bool + MountVolume func(waitForAttachTimeout time.Duration, volumeToMount VolumeToMount, ...) error + ReconstructVolumeOperation func(volumeMode v1.PersistentVolumeMode, plugin volume.VolumePlugin, ...) (*volume.Spec, error) + UnmountDevice func(deviceToDetach AttachedVolume, ...) error + UnmountVolume func(volumeToUnmount MountedVolume, ...) error + VerifyControllerAttachedVolume func(volumeToMount VolumeToMount, nodeName types.NodeName, ...) error + VerifyVolumesAreAttached func(volumesToVerify map[types.NodeName][]AttachedVolume, ...) + VerifyVolumesAreAttachedPerNode func(AttachedVolumes []AttachedVolume, nodeName types.NodeName, ...) error + func NewOperationExecutor(operationGenerator OperationGenerator) OperationExecutor + type OperationGenerator interface + GenerateAttachVolumeFunc func(volumeToAttach VolumeToAttach, ...) volumetypes.GeneratedOperations + GenerateBulkVolumeVerifyFunc func(map[types.NodeName][]*volume.Spec, string, ...) (volumetypes.GeneratedOperations, error) + GenerateDetachVolumeFunc func(volumeToDetach AttachedVolume, verifySafeToDetach bool, ...) (volumetypes.GeneratedOperations, error) + GenerateExpandInUseVolumeFunc func(volumeToMount VolumeToMount, ...) (volumetypes.GeneratedOperations, error) + GenerateExpandVolumeFunc func(*v1.PersistentVolumeClaim, *v1.PersistentVolume) (volumetypes.GeneratedOperations, error) + GenerateMapVolumeFunc func(waitForAttachTimeout time.Duration, volumeToMount VolumeToMount, ...) (volumetypes.GeneratedOperations, error) + GenerateMountVolumeFunc func(waitForAttachTimeout time.Duration, volumeToMount VolumeToMount, ...) volumetypes.GeneratedOperations + GenerateUnmapDeviceFunc func(deviceToDetach AttachedVolume, ...) (volumetypes.GeneratedOperations, error) + GenerateUnmapVolumeFunc func(volumeToUnmount MountedVolume, ...) (volumetypes.GeneratedOperations, error) + GenerateUnmountDeviceFunc func(deviceToDetach AttachedVolume, ...) (volumetypes.GeneratedOperations, error) + GenerateUnmountVolumeFunc func(volumeToUnmount MountedVolume, ...) (volumetypes.GeneratedOperations, error) + GenerateVerifyControllerAttachedVolumeFunc func(volumeToMount VolumeToMount, nodeName types.NodeName, ...) (volumetypes.GeneratedOperations, error) + GenerateVolumesAreAttachedFunc func(attachedVolumes []AttachedVolume, nodeName types.NodeName, ...) (volumetypes.GeneratedOperations, error) + GetVolumePluginMgr func() *volume.VolumePluginMgr + func NewFakeOGCounter(opFunc func() (error, error)) OperationGenerator + func NewOperationGenerator(kubeClient clientset.Interface, volumePluginMgr *volume.VolumePluginMgr, ...) OperationGenerator + type VolumeLogger interface + GenerateError func(prefixMsg string, err error) (simpleErr, detailedErr error) + GenerateErrorDetailed func(prefixMsg string, err error) (detailedErr error) + GenerateMsg func(prefixMsg, suffixMsg string) (simpleMsg, detailedMsg string) + GenerateMsgDetailed func(prefixMsg, suffixMsg string) (detailedMsg string) + type VolumeToAttach struct + MultiAttachErrorReported bool + NodeName types.NodeName + ScheduledPods []*v1.Pod + VolumeName v1.UniqueVolumeName + VolumeSpec *volume.Spec + func (volume *VolumeToAttach) GenerateError(prefixMsg string, err error) (simpleErr, detailedErr error) + func (volume *VolumeToAttach) GenerateErrorDetailed(prefixMsg string, err error) (detailedErr error) + func (volume *VolumeToAttach) GenerateMsg(prefixMsg, suffixMsg string) (simpleMsg, detailedMsg string) + func (volume *VolumeToAttach) GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string) + type VolumeToMount struct + DesiredSizeLimit *resource.Quantity + DevicePath string + OuterVolumeSpecName string + PluginIsAttachable bool + PluginIsDeviceMountable bool + Pod *v1.Pod + PodName volumetypes.UniquePodName + ReportedInUse bool + VolumeGidValue string + VolumeName v1.UniqueVolumeName + VolumeSpec *volume.Spec + func (volume *VolumeToMount) GenerateError(prefixMsg string, err error) (simpleErr, detailedErr error) + func (volume *VolumeToMount) GenerateErrorDetailed(prefixMsg string, err error) (detailedErr error) + func (volume *VolumeToMount) GenerateMsg(prefixMsg, suffixMsg string) (simpleMsg, detailedMsg string) + func (volume *VolumeToMount) GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string)
Go to main page