diff options
Diffstat (limited to 'pkg/driver')
| -rw-r--r-- | pkg/driver/driver.go | 1 | ||||
| -rw-r--r-- | pkg/driver/mounter_seaweedfs.go | 3 |
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) |