mirror of
https://github.com/ceph/ceph-csi.git
synced 2024-11-10 00:10:20 +00:00
25617929f0
`cap` builtin function returns the capacity of a type. Its not good practice to use this builtin function for other variable names, removing it here Ref# https://golang.org/pkg/builtin/#cap Signed-off-by: Humble Chirammal <hchiramm@redhat.com>
94 lines
3.0 KiB
Go
94 lines
3.0 KiB
Go
package util
|
|
|
|
import (
|
|
"github.com/container-storage-interface/spec/lib/go/csi"
|
|
"google.golang.org/grpc/codes"
|
|
"google.golang.org/grpc/status"
|
|
)
|
|
|
|
// ValidateNodeStageVolumeRequest validates the node stage request.
|
|
func ValidateNodeStageVolumeRequest(req *csi.NodeStageVolumeRequest) error {
|
|
if req.GetVolumeCapability() == nil {
|
|
return status.Error(codes.InvalidArgument, "volume capability missing in request")
|
|
}
|
|
|
|
if req.GetVolumeId() == "" {
|
|
return status.Error(codes.InvalidArgument, "volume ID missing in request")
|
|
}
|
|
|
|
if req.GetStagingTargetPath() == "" {
|
|
return status.Error(codes.InvalidArgument, "staging target path missing in request")
|
|
}
|
|
|
|
if req.GetSecrets() == nil || len(req.GetSecrets()) == 0 {
|
|
return status.Error(codes.InvalidArgument, "stage secrets cannot be nil or empty")
|
|
}
|
|
|
|
// validate stagingpath exists
|
|
ok := checkDirExists(req.GetStagingTargetPath())
|
|
if !ok {
|
|
return status.Errorf(codes.InvalidArgument, "staging path %s does not exists on node", req.GetStagingTargetPath())
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ValidateNodeUnstageVolumeRequest validates the node unstage request.
|
|
func ValidateNodeUnstageVolumeRequest(req *csi.NodeUnstageVolumeRequest) error {
|
|
if req.GetVolumeId() == "" {
|
|
return status.Error(codes.InvalidArgument, "volume ID missing in request")
|
|
}
|
|
|
|
if req.GetStagingTargetPath() == "" {
|
|
return status.Error(codes.InvalidArgument, "staging target path missing in request")
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// ValidateNodePublishVolumeRequest validates the node publish request.
|
|
func ValidateNodePublishVolumeRequest(req *csi.NodePublishVolumeRequest) error {
|
|
if req.GetVolumeCapability() == nil {
|
|
return status.Error(codes.InvalidArgument, "volume capability missing in request")
|
|
}
|
|
|
|
if req.GetVolumeId() == "" {
|
|
return status.Error(codes.InvalidArgument, "volume ID missing in request")
|
|
}
|
|
|
|
if req.GetTargetPath() == "" {
|
|
return status.Error(codes.InvalidArgument, "target path missing in request")
|
|
}
|
|
|
|
if req.GetStagingTargetPath() == "" {
|
|
return status.Error(codes.InvalidArgument, "staging target path missing in request")
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// ValidateNodeUnpublishVolumeRequest validates the node unpublish request.
|
|
func ValidateNodeUnpublishVolumeRequest(req *csi.NodeUnpublishVolumeRequest) error {
|
|
if req.GetVolumeId() == "" {
|
|
return status.Error(codes.InvalidArgument, "volume ID missing in request")
|
|
}
|
|
|
|
if req.GetTargetPath() == "" {
|
|
return status.Error(codes.InvalidArgument, "target path missing in request")
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// CheckReadOnlyManyIsSupported checks the request is to create ReadOnlyMany
|
|
// volume is from source as empty ReadOnlyMany is not supported.
|
|
func CheckReadOnlyManyIsSupported(req *csi.CreateVolumeRequest) error {
|
|
for _, capability := range req.GetVolumeCapabilities() {
|
|
if m := capability.GetAccessMode().Mode; m == csi.VolumeCapability_AccessMode_MULTI_NODE_READER_ONLY || m == csi.VolumeCapability_AccessMode_SINGLE_NODE_READER_ONLY {
|
|
if req.GetVolumeContentSource() == nil {
|
|
return status.Error(codes.InvalidArgument, "readOnly accessMode is supported only with content source")
|
|
}
|
|
}
|
|
}
|
|
return nil
|
|
}
|