[#220] cmd/neofs-node: Configure Shard's write cache usage

Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
Leonard Lyubich 2020-11-30 20:03:15 +03:00 committed by Alex Vanin
parent cbdcfb9159
commit 2eb83624cf

View file

@ -114,6 +114,8 @@ const (
cfgLocalStorageSection = "storage" cfgLocalStorageSection = "storage"
cfgStorageShardSection = "shard" cfgStorageShardSection = "shard"
cfgShardUseWriteCache = "use_write_cache"
cfgBlobStorSection = "blobstor" cfgBlobStorSection = "blobstor"
cfgBlobStorCompress = "compress" cfgBlobStorCompress = "compress"
cfgBlobStorShallowDepth = "shallow_depth" cfgBlobStorShallowDepth = "shallow_depth"
@ -436,6 +438,10 @@ func initShardOptions(c *cfg) {
strconv.Itoa(i), strconv.Itoa(i),
) )
useCache := c.viper.GetBool(
configPath(prefix, cfgShardUseWriteCache),
)
blobPrefix := configPath(prefix, cfgBlobStorSection) blobPrefix := configPath(prefix, cfgBlobStorSection)
blobPath := c.viper.GetString( blobPath := c.viper.GetString(
@ -510,9 +516,11 @@ func initShardOptions(c *cfg) {
meta.WithPath(metaPath), meta.WithPath(metaPath),
meta.WithPermissions(metaPerm), meta.WithPermissions(metaPerm),
), ),
shard.WithWriteCache(useCache),
}) })
c.log.Info("storage shard options", c.log.Info("storage shard options",
zap.Bool("with write cache", useCache),
zap.String("BLOB path", blobPath), zap.String("BLOB path", blobPath),
zap.Stringer("BLOB permissions", blobPerm), zap.Stringer("BLOB permissions", blobPerm),
zap.Bool("BLOB compress", compressObjects), zap.Bool("BLOB compress", compressObjects),