eosfs: Expose the parms ReadUsesLocalTemp and WriteUsesLocalTemp

Author: Fabrizio Furano

pkg/storage/utils/eosfs/config.go

@@ -111,4 +111,14 @@ type Config struct {
 	// URI of the EOS MGM grpc server
 	// Default is empty
 	GrpcURI string `mapstructure:"master_grpc_uri"`
+
+	// Normally the eosgrpc plugin streams data on the fly.
+	// Setting this to true will make reva use the temp cachedirectory
+	// as intermediate step for read operations
+	ReadUsesLocalTemp bool `mapstructure:"read_uses_local_temp"`
+
+	// Normally the eosgrpc plugin streams data on the fly.
+	// Setting this to true will make reva use the temp cachedirectory
+	// as intermediate step for write operations
+	WriteUsesLocalTemp bool `mapstructure:"write_uses_local_temp"`
 }

pkg/storage/utils/eosfs/eosfs.go

@@ -145,15 +145,17 @@ func NewEOSFS(c *Config) (storage.FS, error) {
 	var eosClient eosclient.EOSClient
 	if c.UseGRPC {
 		eosClientOpts := &eosgrpc.Options{
-			XrdcopyBinary:    c.XrdcopyBinary,
-			URL:              c.MasterURL,
-			GrpcURI:          c.GrpcURI,
-			CacheDirectory:   c.CacheDirectory,
-			UseKeytab:        c.UseKeytab,
-			Keytab:           c.Keytab,
-			Authkey:          c.GRPCAuthkey,
-			SecProtocol:      c.SecProtocol,
-			VersionInvariant: c.VersionInvariant,
+			XrdcopyBinary:      c.XrdcopyBinary,
+			URL:                c.MasterURL,
+			GrpcURI:            c.GrpcURI,
+			CacheDirectory:     c.CacheDirectory,
+			UseKeytab:          c.UseKeytab,
+			Keytab:             c.Keytab,
+			Authkey:            c.GRPCAuthkey,
+			SecProtocol:        c.SecProtocol,
+			VersionInvariant:   c.VersionInvariant,
+			ReadUsesLocalTemp:  c.ReadUsesLocalTemp,
+			WriteUsesLocalTemp: c.WriteUsesLocalTemp,
 		}
 		eosClient = eosgrpc.New(eosClientOpts)
 	} else {