diff --git a/internal/cephfs/errors.go b/internal/cephfs/errors.go index f9dc51f31..02fdaf8ba 100644 --- a/internal/cephfs/errors.go +++ b/internal/cephfs/errors.go @@ -16,7 +16,10 @@ limitations under the License. package cephfs -import "errors" +import ( + "errors" + "fmt" +) var ( // ErrInvalidVolID is returned when a CSI passed VolumeID is not conformant to any known volume ID @@ -25,6 +28,17 @@ var ( // ErrNonStaticVolume is returned when a volume is detected as not being // statically provisioned. ErrNonStaticVolume = errors.New("volume not static") + // ErrVolNotEmpty is returned when a subvolume has snapshots in it. + ErrVolNotEmpty = fmt.Errorf("%v", "Error ENOTEMPTY") // ErrVolumeNotFound is returned when a subvolume is not found in CephFS. - ErrVolumeNotFound = errors.New("volume not found") + ErrVolumeNotFound = fmt.Errorf("%v", "Error ENOENT") + // ErrInvalidCommand is returned when a command is not known to the cluster + ErrInvalidCommand = fmt.Errorf("%v", "Error EINVAL") + // ErrSnapNotFound is returned when snap name passed is not found in the list of snapshots for the + // given image. + ErrSnapNotFound = fmt.Errorf("%v", "Error ENOENT") + // ErrSnapProtectionExist is returned when the snapshot is already protected + ErrSnapProtectionExist = fmt.Errorf("%v", "Error EEXIST") + // ErrCloneInProgress is returned when snapshot clone state is `in progress` + ErrCloneInProgress = fmt.Errorf("in progress") )