github/csi-driver-nvmf
1
0
Fork 0
mirror of https://github.com/kubernetes-csi/csi-driver-nvmf.git synced 2025-07-02 01:11:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: add NodeStageVolume() and NodeUnstageVolume() skeletons with validation for request arguments

Browse Source 
Signed-off-by: cheolho.kang <cheolho.kang@samsung.com>
This commit is contained in:
cheolho.kang 2025-03-20 09:20:56 +09:00
parent 29c61f1bba
commit e6be700ac2
1 changed files with 36 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
pkg/nvmf/nodeserver.go
View File

@ -48,6 +48,13 @@ func (n *NodeServer) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCa
},
},
},
{
Type: &csi.NodeServiceCapability_Rpc{
Rpc: &csi.NodeServiceCapability_RPC{
Type: csi.NodeServiceCapability_RPC_STAGE_UNSTAGE_VOLUME,
},
},
},
},
}, nil
}
@ -102,11 +109,40 @@ func (n *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpub
return &csi.NodeUnpublishVolumeResponse{}, nil
}
// NodeStageVolume attaches the NVMe device to the node
func (n *NodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error) {
volumeID := req.GetVolumeId()
if volumeID == "" {
return nil, status.Error(codes.InvalidArgument, "NodeStageVolume Volume ID must be required")
}
// Check for supported volume capabilities
if req.GetVolumeCapability() == nil {
return nil, status.Error(codes.InvalidArgument, "NodeStageVolume Volume capability is required")
}
// Check for staging target path
if req.GetStagingTargetPath() == "" {
return nil, status.Error(codes.InvalidArgument, "NodeStageVolume Staging target path is required")
}
klog.V(4).Infof("NodeStageVolume called for volume %s", volumeID)
return &csi.NodeStageVolumeResponse{}, nil
}
// NodeUnstageVolume detaches the NVMe device from the node
func (n *NodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error) {
// Validate parameters
if req.VolumeId == "" {
return nil, status.Error(codes.InvalidArgument, "NodeUnstageVolume Volume ID must be provided")
}
if req.StagingTargetPath == "" {
return nil, status.Error(codes.InvalidArgument, "NodeUnstageVolume Staging target path must be provided")
}
klog.V(4).Infof("NodeUnstageVolume called for volume %s", req.VolumeId)
return &csi.NodeUnstageVolumeResponse{}, nil
}