aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/mounter_seaweedfs.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-03-18 00:25:31 -0700
committerchrislu <chris.lu@gmail.com>2022-03-18 00:25:31 -0700
commit269595f398722c93a01b27187ee71fc37fbf7c37 (patch)
tree41ef32199f6d776074fb8407dae7d5d893000f37 /pkg/driver/mounter_seaweedfs.go
parent0eb9dcdd3c63e7873212f6acf818a0161d087821 (diff)
downloadseaweedfs-csi-driver-269595f398722c93a01b27187ee71fc37fbf7c37.tar.xz
seaweedfs-csi-driver-269595f398722c93a01b27187ee71fc37fbf7c37.zip
set disk type by volume create request parameters
related to https://github.com/seaweedfs/seaweedfs-csi-driver/issues/50
Diffstat (limited to 'pkg/driver/mounter_seaweedfs.go')
-rw-r--r--pkg/driver/mounter_seaweedfs.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/pkg/driver/mounter_seaweedfs.go b/pkg/driver/mounter_seaweedfs.go
index 7c64314..2d0eba9 100644
--- a/pkg/driver/mounter_seaweedfs.go
+++ b/pkg/driver/mounter_seaweedfs.go
@@ -82,6 +82,10 @@ func (seaweedFs *seaweedFsMounter) Mount(target string) error {
args = append(args, fmt.Sprintf("-map.gid=%s", seaweedFs.driver.GidMap))
}
+ if seaweedFs.driver.DiskType != "" {
+ args = append(args, fmt.Sprintf("-disk=%s", seaweedFs.driver.DiskType))
+ }
+
err := fuseMount(target, seaweedFsCmd, args)
if err != nil {
glog.Errorf("mount %v %s to %s: %s", seaweedFs.driver.filers, seaweedFs.path, target, err)