diff --git a/pkg/storage/utils/eosfs/config.go b/pkg/storage/utils/eosfs/config.go index 515d7c0452..acda91fb69 100644 --- a/pkg/storage/utils/eosfs/config.go +++ b/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"` } diff --git a/pkg/storage/utils/eosfs/eosfs.go b/pkg/storage/utils/eosfs/eosfs.go index 6235492cf3..406db86531 100644 --- a/pkg/storage/utils/eosfs/eosfs.go +++ b/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 {