Expose more juicefs options (#251)

- expose buffer size
- expose prefetch worker counter

pkg/common/config.default.yaml

@@ -27,6 +27,8 @@ storage:
     awsSecretKey: test
     blockSize: 4096
     cacheSize: 0
+    prefetch: 1
+    bufferSize: 300
 gateway:
   host: beta9-gateway.beta9
   externalURL: http://localhost:1994

pkg/storage/juicefs.go

@@ -28,15 +28,26 @@ func (s *JuiceFsStorage) Mount(localPath string) error {
 
 	cacheSize := strconv.FormatInt(s.config.CacheSize, 10)
 
+	prefetch := strconv.FormatInt(s.config.Prefetch, 10)
+	if s.config.Prefetch <= 0 {
+		prefetch = "1"
+	}
+
+	bufferSize := strconv.FormatInt(s.config.BufferSize, 10)
+	if s.config.BufferSize <= 0 {
+		prefetch = "300"
+	}
+
 	s.mountCmd = exec.Command(
 		"juicefs",
 		"mount",
 		s.config.RedisURI,
 		localPath,
 		"-d",
 		"--bucket", s.config.AWSS3Bucket,
-		"--cache-size",
-		cacheSize,
+		"--cache-size", cacheSize,
+		"--prefetch", prefetch,
+		"--buffer-size", bufferSize,
 		"--no-bgjob",
 		"--no-usage-report",
 	)

pkg/types/config.go

@@ -142,6 +142,8 @@ type JuiceFSConfig struct {
 	AWSSecretKey string `key:"awsSecretKey" json:"aws_secret_key"`
 	CacheSize    int64  `key:"cacheSize" json:"cache_size"`
 	BlockSize    int64  `key:"blockSize" json:"block_size"`
+	Prefetch     int64  `key:"prefetch" json:"prefetch"`
+	BufferSize   int64  `key:"bufferSize" json:"buffer_size"`
 }
 
 type MountPointConfig struct {