feat: add configurable metadata cache TTL setting

Author: molnia1311

cmd/seaweedfs-csi-driver/main.go

@@ -25,6 +25,7 @@ var (
 	concurrentWriters = flag.Int("concurrentWriters", 128, "limit concurrent goroutine writers if not 0")
 	concurrentReaders = flag.Int("concurrentReaders", 128, "limit concurrent chunk fetches for read operations")
 	cacheCapacityMB   = flag.Int("cacheCapacityMB", 0, "local file chunk cache capacity in MB")
+	cacheMetaTtlSec   = flag.Int("cacheMetaTtlSec", 60, "metadata cache TTL in seconds")
 	cacheDir          = flag.String("cacheDir", os.TempDir(), "local cache directory for file chunks and meta data")
 	uidMap            = flag.String("map.uid", "", "map local uid to uid on filer, comma-separated <local_uid>:<filer_uid>")
 	gidMap            = flag.String("map.gid", "", "map local gid to gid on filer, comma-separated <local_gid>:<filer_gid>")
@@ -88,6 +89,7 @@ func main() {
 	drv.ConcurrentWriters = *concurrentWriters
 	drv.ConcurrentReaders = *concurrentReaders
 	drv.CacheCapacityMB = *cacheCapacityMB
+	drv.CacheMetaTtlSec = *cacheMetaTtlSec
 	drv.CacheDir = *cacheDir
 	drv.UidMap = *uidMap
 	drv.GidMap = *gidMap

deploy/helm/seaweedfs-csi-driver/templates/daemonset.yaml

@@ -67,6 +67,9 @@ spec:
             {{- with .Values.cacheCapacityMB }}
             - --cacheCapacityMB={{ . }}
             {{- end }}
+            {{- with .Values.cacheMetaTtlSec }}
+            - --cacheMetaTtlSec={{ . }}
+            {{- end }}
           env:
             - name: CSI_ENDPOINT
               value: unix:///csi/csi.sock

deploy/helm/seaweedfs-csi-driver/values.yaml

@@ -6,6 +6,7 @@ isDefaultStorageClass: false
 tlsSecret: ""
 #logVerbosity: 4
 #cacheCapacityMB: 0
+#cacheMetaTtlSec: 60
 
 #concurrentWriters: 128
 #concurrentReaders: 128

pkg/driver/driver.go

@@ -42,6 +42,7 @@ type SeaweedFsDriver struct {
 	ConcurrentWriters int
 	ConcurrentReaders int
 	CacheCapacityMB   int
+	CacheMetaTtlSec   int
 	CacheDir          string
 	UidMap            string
 	GidMap            string

pkg/driver/mounter.go

@@ -134,6 +134,7 @@ func (m *mountServiceMounter) buildMountArgs(targetPath, cacheDir, localSocket s
 		"filer":              strings.Join(filers, ","),
 		"filer.path":         filerPath,
 		"cacheCapacityMB":    strconv.Itoa(m.driver.CacheCapacityMB),
+		"cacheMetaTtlSec":    strconv.Itoa(m.driver.CacheMetaTtlSec),
 		"concurrentReaders":  strconv.Itoa(m.driver.ConcurrentReaders),
 		"concurrentWriters":  strconv.Itoa(m.driver.ConcurrentWriters),
 		"map.uid":            m.driver.UidMap,