mirror of
https://github.com/kubernetes-csi/csi-driver-nvmf.git
synced 2025-05-05 22:26:30 +00:00
3e07ae4e60
1. add .prow.sh 2. add a symlink in Makefile related to release-tools. 3. modify some code style to pass fmt test. Signed-off-by: Meinhard Zhou <zhouenhua@bytedance.com>
64 lines
1.7 KiB
Go
64 lines
1.7 KiB
Go
/*
|
|
Copyright 2021 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package nvmf
|
|
|
|
import (
|
|
"github.com/container-storage-interface/spec/lib/go/csi"
|
|
"k8s.io/utils/exec"
|
|
"k8s.io/utils/mount"
|
|
)
|
|
|
|
type nvmfDiskMounter struct {
|
|
*nvmfDiskInfo
|
|
readOnly bool
|
|
fsType string
|
|
mountOptions []string
|
|
mounter *mount.SafeFormatAndMount
|
|
exec exec.Interface
|
|
targetPath string
|
|
connector *Connector
|
|
}
|
|
|
|
type nvmfDiskUnMounter struct {
|
|
mounter mount.Interface
|
|
exec exec.Interface
|
|
}
|
|
|
|
func getNVMfDiskMounter(nvmfInfo *nvmfDiskInfo, req *csi.NodePublishVolumeRequest) *nvmfDiskMounter {
|
|
readOnly := req.GetReadonly()
|
|
fsType := req.GetVolumeCapability().GetMount().GetFsType()
|
|
mountOptions := req.GetVolumeCapability().GetMount().GetMountFlags()
|
|
|
|
return &nvmfDiskMounter{
|
|
nvmfDiskInfo: nvmfInfo,
|
|
readOnly: readOnly,
|
|
fsType: fsType,
|
|
mountOptions: mountOptions,
|
|
mounter: &mount.SafeFormatAndMount{Interface: mount.New(""), Exec: exec.New()},
|
|
exec: exec.New(),
|
|
targetPath: req.GetTargetPath(),
|
|
connector: getConnector(nvmfInfo),
|
|
}
|
|
}
|
|
|
|
func getNVMfDiskUnMounter(req *csi.NodeUnpublishVolumeRequest) *nvmfDiskUnMounter {
|
|
return &nvmfDiskUnMounter{
|
|
mounter: mount.New(""),
|
|
exec: exec.New(),
|
|
}
|
|
}
|