type OperationExecutor … // NewOperationExecutor returns a new instance of OperationExecutor. func NewOperationExecutor( operationGenerator OperationGenerator) OperationExecutor { … } type MarkVolumeOpts … type ActualStateOfWorldMounterUpdater … type ActualStateOfWorldAttacherUpdater … type VolumeLogger … // Generates an error string with the format ": <err>" if err exists func errSuffix(err error) string { … } // Generate a detailed error msg for logs func generateVolumeMsgDetailed(prefixMsg, suffixMsg, volumeName, details string) (detailedMsg string) { … } // Generate a simplified error msg for events and a detailed error msg for logs func generateVolumeMsg(prefixMsg, suffixMsg, volumeName, details string) (simpleMsg, detailedMsg string) { … } type VolumeToAttach … // GenerateMsgDetailed returns detailed msgs for volumes to attach func (volume *VolumeToAttach) GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string) { … } // GenerateMsg returns simple and detailed msgs for volumes to attach func (volume *VolumeToAttach) GenerateMsg(prefixMsg, suffixMsg string) (simpleMsg, detailedMsg string) { … } // GenerateErrorDetailed returns detailed errors for volumes to attach func (volume *VolumeToAttach) GenerateErrorDetailed(prefixMsg string, err error) (detailedErr error) { … } // GenerateError returns simple and detailed errors for volumes to attach func (volume *VolumeToAttach) GenerateError(prefixMsg string, err error) (simpleErr, detailedErr error) { … } // String combines key fields of the volume for logging in text format. func (volume *VolumeToAttach) String() string { … } // MarshalLog combines key fields of the volume for logging in a structured format. func (volume *VolumeToAttach) MarshalLog() interface{ … } var _ … var _ … type VolumeToMount … type DeviceMountState … const DeviceGloballyMounted … const DeviceMountUncertain … const DeviceNotMounted … type VolumeMountState … const VolumeMounted … const VolumeMountUncertain … const VolumeNotMounted … type MountPreConditionFailed … func (err *MountPreConditionFailed) Error() string { … } func NewMountPreConditionFailedError(msg string) *MountPreConditionFailed { … } func IsMountFailedPreconditionError(err error) bool { … } // GenerateMsgDetailed returns detailed msgs for volumes to mount func (volume *VolumeToMount) GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string) { … } // GenerateMsg returns simple and detailed msgs for volumes to mount func (volume *VolumeToMount) GenerateMsg(prefixMsg, suffixMsg string) (simpleMsg, detailedMsg string) { … } // GenerateErrorDetailed returns detailed errors for volumes to mount func (volume *VolumeToMount) GenerateErrorDetailed(prefixMsg string, err error) (detailedErr error) { … } // GenerateError returns simple and detailed errors for volumes to mount func (volume *VolumeToMount) GenerateError(prefixMsg string, err error) (simpleErr, detailedErr error) { … } type AttachedVolume … // GenerateMsgDetailed returns detailed msgs for attached volumes func (volume *AttachedVolume) GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string) { … } // GenerateMsg returns simple and detailed msgs for attached volumes func (volume *AttachedVolume) GenerateMsg(prefixMsg, suffixMsg string) (simpleMsg, detailedMsg string) { … } // GenerateErrorDetailed returns detailed errors for attached volumes func (volume *AttachedVolume) GenerateErrorDetailed(prefixMsg string, err error) (detailedErr error) { … } // GenerateError returns simple and detailed errors for attached volumes func (volume *AttachedVolume) GenerateError(prefixMsg string, err error) (simpleErr, detailedErr error) { … } // String combines key fields of the volume for logging in text format. func (volume *AttachedVolume) String() string { … } // MarshalLog combines key fields of the volume for logging in a structured format. func (volume *AttachedVolume) MarshalLog() interface{ … } var _ … var _ … type MountedVolume … // GenerateMsgDetailed returns detailed msgs for mounted volumes func (volume *MountedVolume) GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string) { … } // GenerateMsg returns simple and detailed msgs for mounted volumes func (volume *MountedVolume) GenerateMsg(prefixMsg, suffixMsg string) (simpleMsg, detailedMsg string) { … } // GenerateErrorDetailed returns simple and detailed errors for mounted volumes func (volume *MountedVolume) GenerateErrorDetailed(prefixMsg string, err error) (detailedErr error) { … } // GenerateError returns simple and detailed errors for mounted volumes func (volume *MountedVolume) GenerateError(prefixMsg string, err error) (simpleErr, detailedErr error) { … } type operationExecutor … func (oe *operationExecutor) IsOperationPending( volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName, nodeName types.NodeName) bool { … } func (oe *operationExecutor) IsOperationSafeToRetry( volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName, nodeName types.NodeName, operationName string) bool { … } func (oe *operationExecutor) AttachVolume( logger klog.Logger, volumeToAttach VolumeToAttach, actualStateOfWorld ActualStateOfWorldAttacherUpdater) error { … } func (oe *operationExecutor) DetachVolume( logger klog.Logger, volumeToDetach AttachedVolume, verifySafeToDetach bool, actualStateOfWorld ActualStateOfWorldAttacherUpdater) error { … } func (oe *operationExecutor) VerifyVolumesAreAttached( attachedVolumes map[types.NodeName][]AttachedVolume, actualStateOfWorld ActualStateOfWorldAttacherUpdater) { … } func (oe *operationExecutor) VerifyVolumesAreAttachedPerNode( attachedVolumes []AttachedVolume, nodeName types.NodeName, actualStateOfWorld ActualStateOfWorldAttacherUpdater) error { … } func (oe *operationExecutor) MountVolume( waitForAttachTimeout time.Duration, volumeToMount VolumeToMount, actualStateOfWorld ActualStateOfWorldMounterUpdater, isRemount bool) error { … } func (oe *operationExecutor) UnmountVolume( volumeToUnmount MountedVolume, actualStateOfWorld ActualStateOfWorldMounterUpdater, podsDir string) error { … } func (oe *operationExecutor) UnmountDevice( deviceToDetach AttachedVolume, actualStateOfWorld ActualStateOfWorldMounterUpdater, hostutil hostutil.HostUtils) error { … } func (oe *operationExecutor) ExpandInUseVolume(volumeToMount VolumeToMount, actualStateOfWorld ActualStateOfWorldMounterUpdater, currentSize resource.Quantity) error { … } func (oe *operationExecutor) VerifyControllerAttachedVolume( logger klog.Logger, volumeToMount VolumeToMount, nodeName types.NodeName, actualStateOfWorld ActualStateOfWorldAttacherUpdater) error { … } // ReconstructVolumeOperation return a func to create volumeSpec from mount path func (oe *operationExecutor) ReconstructVolumeOperation( volumeMode v1.PersistentVolumeMode, plugin volume.VolumePlugin, mapperPlugin volume.BlockVolumePlugin, uid types.UID, podName volumetypes.UniquePodName, volumeSpecName string, volumePath string, pluginName string) (volume.ReconstructedVolume, error) { … }
Codebase Browser
kubernetes