diff options
Diffstat (limited to 'cmd')
| -rw-r--r-- | cmd/seaweedfs-csi-driver/main.go | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/cmd/seaweedfs-csi-driver/main.go b/cmd/seaweedfs-csi-driver/main.go index a654992..2671f0b 100644 --- a/cmd/seaweedfs-csi-driver/main.go +++ b/cmd/seaweedfs-csi-driver/main.go @@ -10,10 +10,11 @@ import ( ) var ( - filer = flag.String("filer", "localhost:8888", "filer server") - endpoint = flag.String("endpoint", "unix://tmp/seaweedfs-csi.sock", "CSI endpoint to accept gRPC calls") - nodeID = flag.String("nodeid", "", "node id") - version = flag.Bool("version", false, "Print the version and exit.") + filer = flag.String("filer", "localhost:8888", "filer server") + endpoint = flag.String("endpoint", "unix://tmp/seaweedfs-csi.sock", "CSI endpoint to accept gRPC calls") + nodeID = flag.String("nodeid", "", "node id") + version = flag.Bool("version", false, "Print the version and exit.") + concurrentWriters = flag.Int("concurrentWriters", 128, "limit concurrent goroutine writers if not 0") ) func main() { @@ -30,5 +31,6 @@ func main() { } drv := driver.NewSeaweedFsDriver(*filer, *nodeID, *endpoint) + drv.ConcurrentWriters = *concurrentWriters drv.Run() } |