support configurable cache directory

fix https://github.com/seaweedfs/seaweedfs-csi-driver/issues/20

2 files changed, 4 insertions, 0 deletions

diff --git a/pkg/driver/driver.go b/pkg/driver/driver.go
index 8307eb8..cad10b6 100644
--- a/pkg/driver/driver.go
+++ b/pkg/driver/driver.go
@@ -39,6 +39,7 @@ type SeaweedFsDriver struct {
 	grpcDialOption    grpc.DialOption
 	ConcurrentWriters int
 	CacheSizeMB       int64
+	CacheDir          string
 }
 
 func NewSeaweedFsDriver(filer, nodeID, endpoint string) *SeaweedFsDriver {
diff --git a/pkg/driver/mounter_seaweedfs.go b/pkg/driver/mounter_seaweedfs.go
index 2ed1238..c46d8c4 100644
--- a/pkg/driver/mounter_seaweedfs.go
+++ b/pkg/driver/mounter_seaweedfs.go
@@ -51,6 +51,9 @@ func (seaweedFs *seaweedFsMounter) Mount(target string) error {
 	if seaweedFs.driver.ConcurrentWriters > 0 {
 		args = append(args, fmt.Sprintf("-concurrentWriters=%d", seaweedFs.driver.ConcurrentWriters))
 	}
+	if seaweedFs.driver.CacheDir != "" {
+		args = append(args, fmt.Sprintf("-cacheDir=%s", seaweedFs.driver.CacheDir))
+	}
 	err := fuseMount(target, seaweedFsCmd, args)
 	if err != nil {
 		glog.Errorf("mount %s %s to %s: %s", seaweedFs.driver.filer, seaweedFs.bucketName, target, err)