aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/mounter_seaweedfs.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-05-31 02:24:20 -0700
committerChris Lu <chris.lu@gmail.com>2020-05-31 02:24:20 -0700
commit5e19cfc577d447604d57f5a8c770ae4acaccfbcd (patch)
tree346309f201de066a11c1fac03e6a89f380bc3deb /pkg/driver/mounter_seaweedfs.go
parentb21fb2e2b62dd9ec3cf13403e87687229424f1e0 (diff)
downloadseaweedfs-csi-driver-5e19cfc577d447604d57f5a8c770ae4acaccfbcd.tar.xz
seaweedfs-csi-driver-5e19cfc577d447604d57f5a8c770ae4acaccfbcd.zip
it can compile now!
Diffstat (limited to 'pkg/driver/mounter_seaweedfs.go')
-rw-r--r--pkg/driver/mounter_seaweedfs.go33
1 files changed, 33 insertions, 0 deletions
diff --git a/pkg/driver/mounter_seaweedfs.go b/pkg/driver/mounter_seaweedfs.go
new file mode 100644
index 0000000..12fa1e7
--- /dev/null
+++ b/pkg/driver/mounter_seaweedfs.go
@@ -0,0 +1,33 @@
+package driver
+
+import (
+ "fmt"
+)
+
+// Implements Mounter
+type seaweedFsMounter struct {
+ bucketName string
+ filerUrl string
+}
+
+const (
+ seaweedFsCmd = "weed"
+)
+
+func newSeaweedFsMounter(bucketName string, cfg *Config) (Mounter, error) {
+ return &seaweedFsMounter{
+ bucketName: bucketName,
+ filerUrl: cfg.Filer,
+ }, nil
+}
+
+func (seaweedFs *seaweedFsMounter) Mount(target string) error {
+ args := []string{
+ "mount",
+ fmt.Sprintf("-dir=%s", target),
+ fmt.Sprintf("-collection=%s", seaweedFs.bucketName),
+ fmt.Sprintf("-filer=%s", seaweedFs.filerUrl),
+ fmt.Sprintf("-filer.path=/buckets/%s", seaweedFs.bucketName),
+ }
+ return fuseMount(target, seaweedFsCmd, args)
+}