type ActualStateOfWorld … type MountedVolume … type AttachedVolume … // DeviceMayBeMounted returns true if device is mounted in global path or is in // uncertain state. func (av AttachedVolume) DeviceMayBeMounted() bool { … } // NewActualStateOfWorld returns a new instance of ActualStateOfWorld. func NewActualStateOfWorld( nodeName types.NodeName, volumePluginMgr *volume.VolumePluginMgr) ActualStateOfWorld { … } // IsVolumeNotAttachedError returns true if the specified error is a // volumeNotAttachedError. func IsVolumeNotAttachedError(err error) bool { … } // IsRemountRequiredError returns true if the specified error is a // remountRequiredError. func IsRemountRequiredError(err error) bool { … } type actualStateOfWorld … type volumeAttachability … const volumeAttachabilityTrue … const volumeAttachabilityFalse … const volumeAttachabilityUncertain … type attachedVolume … type mountedPod … func (asw *actualStateOfWorld) MarkVolumeAsAttached( logger klog.Logger, volumeName v1.UniqueVolumeName, volumeSpec *volume.Spec, _ types.NodeName, devicePath string) error { … } func (asw *actualStateOfWorld) AddAttachUncertainReconstructedVolume( volumeName v1.UniqueVolumeName, volumeSpec *volume.Spec, _ types.NodeName, devicePath string) error { … } func (asw *actualStateOfWorld) MarkVolumeAsUncertain( logger klog.Logger, volumeName v1.UniqueVolumeName, volumeSpec *volume.Spec, _ types.NodeName) error { … } func (asw *actualStateOfWorld) MarkVolumeAsDetached( volumeName v1.UniqueVolumeName, nodeName types.NodeName) { … } func (asw *actualStateOfWorld) MarkVolumeExpansionFailedWithFinalError(volumeName v1.UniqueVolumeName) { … } func (asw *actualStateOfWorld) RemoveVolumeFromFailedWithFinalErrors(volumeName v1.UniqueVolumeName) { … } func (asw *actualStateOfWorld) CheckVolumeInFailedExpansionWithFinalErrors(volumeName v1.UniqueVolumeName) bool { … } func (asw *actualStateOfWorld) IsVolumeReconstructed(volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName) bool { … } func (asw *actualStateOfWorld) IsVolumeDeviceReconstructed(volumeName v1.UniqueVolumeName) bool { … } func (asw *actualStateOfWorld) CheckAndMarkVolumeAsUncertainViaReconstruction(opts operationexecutor.MarkVolumeOpts) (bool, error) { … } func (asw *actualStateOfWorld) CheckAndMarkDeviceUncertainViaReconstruction(volumeName v1.UniqueVolumeName, deviceMountPath string) bool { … } func (asw *actualStateOfWorld) MarkVolumeAsMounted(markVolumeOpts operationexecutor.MarkVolumeOpts) error { … } func (asw *actualStateOfWorld) AddVolumeToReportAsAttached(logger klog.Logger, volumeName v1.UniqueVolumeName, nodeName types.NodeName) { … } func (asw *actualStateOfWorld) RemoveVolumeFromReportAsAttached(volumeName v1.UniqueVolumeName, nodeName types.NodeName) error { … } func (asw *actualStateOfWorld) MarkVolumeAsUnmounted( podName volumetypes.UniquePodName, volumeName v1.UniqueVolumeName) error { … } func (asw *actualStateOfWorld) MarkDeviceAsMounted( volumeName v1.UniqueVolumeName, devicePath, deviceMountPath, seLinuxMountContext string) error { … } func (asw *actualStateOfWorld) MarkDeviceAsUncertain( volumeName v1.UniqueVolumeName, devicePath, deviceMountPath, seLinuxMountContext string) error { … } func (asw *actualStateOfWorld) MarkVolumeMountAsUncertain(markVolumeOpts operationexecutor.MarkVolumeOpts) error { … } func (asw *actualStateOfWorld) MarkDeviceAsUnmounted( volumeName v1.UniqueVolumeName) error { … } func (asw *actualStateOfWorld) UpdateReconstructedDevicePath(volumeName v1.UniqueVolumeName, devicePath string) { … } func (asw *actualStateOfWorld) UpdateReconstructedVolumeAttachability(volumeName v1.UniqueVolumeName, attachable bool) { … } func (asw *actualStateOfWorld) GetDeviceMountState(volumeName v1.UniqueVolumeName) operationexecutor.DeviceMountState { … } func (asw *actualStateOfWorld) MarkForInUseExpansionError(volumeName v1.UniqueVolumeName) { … } func (asw *actualStateOfWorld) GetVolumeMountState(volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName) operationexecutor.VolumeMountState { … } func (asw *actualStateOfWorld) IsVolumeMountedElsewhere(volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName) bool { … } // addVolume adds the given volume to the cache indicating the specified // volume is attached to this node. If no volume name is supplied, a unique // volume name is generated from the volumeSpec and returned on success. If a // volume with the same generated name already exists, this is a noop. If no // volume plugin can support the given volumeSpec or more than one plugin can // support it, an error is returned. func (asw *actualStateOfWorld) addVolume( volumeName v1.UniqueVolumeName, volumeSpec *volume.Spec, devicePath string, attachability volumeAttachability) error { … } func (asw *actualStateOfWorld) AddPodToVolume(markVolumeOpts operationexecutor.MarkVolumeOpts) error { … } func (asw *actualStateOfWorld) MarkVolumeAsResized(volumeName v1.UniqueVolumeName, claimSize resource.Quantity) bool { … } func (asw *actualStateOfWorld) MarkRemountRequired( podName volumetypes.UniquePodName) { … } func (asw *actualStateOfWorld) SetDeviceMountState( volumeName v1.UniqueVolumeName, deviceMountState operationexecutor.DeviceMountState, devicePath, deviceMountPath, seLinuxMountContext string) error { … } func (asw *actualStateOfWorld) InitializeClaimSize(logger klog.Logger, volumeName v1.UniqueVolumeName, claimSize resource.Quantity) { … } func (asw *actualStateOfWorld) GetClaimSize(volumeName v1.UniqueVolumeName) resource.Quantity { … } func (asw *actualStateOfWorld) DeletePodFromVolume( podName volumetypes.UniquePodName, volumeName v1.UniqueVolumeName) error { … } func (asw *actualStateOfWorld) DeleteVolume(volumeName v1.UniqueVolumeName) error { … } func (asw *actualStateOfWorld) PodExistsInVolume(podName volumetypes.UniquePodName, volumeName v1.UniqueVolumeName, desiredVolumeSize resource.Quantity, seLinuxLabel string) (bool, string, error) { … } func (asw *actualStateOfWorld) PodHasMountedVolumes(podName volumetypes.UniquePodName) bool { … } func (asw *actualStateOfWorld) volumeNeedsExpansion(volumeObj attachedVolume, desiredVolumeSize resource.Quantity) (resource.Quantity, bool) { … } func (asw *actualStateOfWorld) PodRemovedFromVolume( podName volumetypes.UniquePodName, volumeName v1.UniqueVolumeName) bool { … } func (asw *actualStateOfWorld) VolumeExistsWithSpecName(podName volumetypes.UniquePodName, volumeSpecName string) bool { … } func (asw *actualStateOfWorld) VolumeExists( volumeName v1.UniqueVolumeName) bool { … } func (asw *actualStateOfWorld) GetMountedVolumes() []MountedVolume { … } // GetAllMountedVolumes returns all volumes which could be locally mounted for a pod. func (asw *actualStateOfWorld) GetAllMountedVolumes() []MountedVolume { … } func (asw *actualStateOfWorld) GetMountedVolumesForPod( podName volumetypes.UniquePodName) []MountedVolume { … } func (asw *actualStateOfWorld) GetMountedVolumeForPodByOuterVolumeSpecName( podName volumetypes.UniquePodName, outerVolumeSpecName string) (MountedVolume, bool) { … } func (asw *actualStateOfWorld) GetPossiblyMountedVolumesForPod( podName volumetypes.UniquePodName) []MountedVolume { … } func (asw *actualStateOfWorld) GetGloballyMountedVolumes() []AttachedVolume { … } func (asw *actualStateOfWorld) GetAttachedVolumes() []AttachedVolume { … } func (asw *actualStateOfWorld) GetUnmountedVolumes() []AttachedVolume { … } func (asw *actualStateOfWorld) newAttachedVolume( attachedVolume *attachedVolume) AttachedVolume { … } var _ … type volumeNotAttachedError … func (err volumeNotAttachedError) Error() string { … } func newVolumeNotAttachedError(volumeName v1.UniqueVolumeName) error { … } var _ … type remountRequiredError … func (err remountRequiredError) Error() string { … } func newRemountRequiredError( volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName) error { … } type FsResizeRequiredError … func (err FsResizeRequiredError) Error() string { … } func newFsResizeRequiredError( volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName, currentSize resource.Quantity) error { … } // IsFSResizeRequiredError returns true if the specified error is a // fsResizeRequiredError. func IsFSResizeRequiredError(err error) bool { … } // getMountedVolume constructs and returns a MountedVolume object from the given // mountedPod and attachedVolume objects. func getMountedVolume( mountedPod *mountedPod, attachedVolume *attachedVolume) MountedVolume { … } type seLinuxMountMismatchError … func (err seLinuxMountMismatchError) Error() string { … } func newSELinuxMountMismatchError(volumeName v1.UniqueVolumeName) error { … } // IsSELinuxMountMismatchError returns true if the specified error is a // seLinuxMountMismatchError. func IsSELinuxMountMismatchError(err error) bool { … }
Codebase Browser
kubernetes