9b241e4a17
Currently, when removing shard special care must be taken with respect to shard numbering. `mode: disabled` allows to leave shard configuration in place while also ignoring it during initialization. This makes disk replacement much more convenient. Signed-off-by: Evgenii Stratonikov <evgeniy@morphbits.ru>
138 lines
3.5 KiB
Go
138 lines
3.5 KiB
Go
package shardconfig
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/nspcc-dev/neofs-node/cmd/neofs-node/config"
|
|
blobstorconfig "github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/engine/shard/blobstor"
|
|
gcconfig "github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/engine/shard/gc"
|
|
metabaseconfig "github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/engine/shard/metabase"
|
|
piloramaconfig "github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/engine/shard/pilorama"
|
|
writecacheconfig "github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/engine/shard/writecache"
|
|
"github.com/nspcc-dev/neofs-node/pkg/local_object_storage/shard/mode"
|
|
)
|
|
|
|
// Config is a wrapper over the config section
|
|
// which provides access to Shard configurations.
|
|
type Config config.Config
|
|
|
|
// SmallSizeLimitDefault is a default limit of small objects payload in bytes.
|
|
const SmallSizeLimitDefault = 1 << 20
|
|
|
|
// From wraps config section into Config.
|
|
func From(c *config.Config) *Config {
|
|
return (*Config)(c)
|
|
}
|
|
|
|
// Compress returns the value of "compress" config parameter.
|
|
//
|
|
// Returns false if the value is not a valid bool.
|
|
func (x *Config) Compress() bool {
|
|
return config.BoolSafe(
|
|
(*config.Config)(x),
|
|
"compress",
|
|
)
|
|
}
|
|
|
|
// UncompressableContentTypes returns the value of "compress_skip_content_types" config parameter.
|
|
//
|
|
// Returns nil if a the value is missing or is invalid.
|
|
func (x *Config) UncompressableContentTypes() []string {
|
|
return config.StringSliceSafe(
|
|
(*config.Config)(x),
|
|
"compression_exclude_content_types")
|
|
}
|
|
|
|
// SmallSizeLimit returns the value of "small_object_size" config parameter.
|
|
//
|
|
// Returns SmallSizeLimitDefault if the value is not a positive number.
|
|
func (x *Config) SmallSizeLimit() uint64 {
|
|
l := config.SizeInBytesSafe(
|
|
(*config.Config)(x),
|
|
"small_object_size",
|
|
)
|
|
|
|
if l > 0 {
|
|
return l
|
|
}
|
|
|
|
return SmallSizeLimitDefault
|
|
}
|
|
|
|
// BlobStor returns "blobstor" subsection as a blobstorconfig.Config.
|
|
func (x *Config) BlobStor() *blobstorconfig.Config {
|
|
return blobstorconfig.From(
|
|
(*config.Config)(x).
|
|
Sub("blobstor"),
|
|
)
|
|
}
|
|
|
|
// Metabase returns "metabase" subsection as a metabaseconfig.Config.
|
|
func (x *Config) Metabase() *metabaseconfig.Config {
|
|
return metabaseconfig.From(
|
|
(*config.Config)(x).
|
|
Sub("metabase"),
|
|
)
|
|
}
|
|
|
|
// WriteCache returns "writecache" subsection as a writecacheconfig.Config.
|
|
func (x *Config) WriteCache() *writecacheconfig.Config {
|
|
return writecacheconfig.From(
|
|
(*config.Config)(x).
|
|
Sub("writecache"),
|
|
)
|
|
}
|
|
|
|
// Pilorama returns "pilorama" subsection as a piloramaconfig.Config.
|
|
func (x *Config) Pilorama() *piloramaconfig.Config {
|
|
return piloramaconfig.From(
|
|
(*config.Config)(x).
|
|
Sub("pilorama"),
|
|
)
|
|
}
|
|
|
|
// GC returns "gc" subsection as a gcconfig.Config.
|
|
func (x *Config) GC() *gcconfig.Config {
|
|
return gcconfig.From(
|
|
(*config.Config)(x).
|
|
Sub("gc"),
|
|
)
|
|
}
|
|
|
|
// RefillMetabase returns the value of "resync_metabase" config parameter.
|
|
//
|
|
// Returns false if the value is not a valid bool.
|
|
func (x *Config) RefillMetabase() bool {
|
|
return config.BoolSafe(
|
|
(*config.Config)(x),
|
|
"resync_metabase",
|
|
)
|
|
}
|
|
|
|
// Mode return the value of "mode" config parameter.
|
|
//
|
|
// Panics if read the value is not one of predefined
|
|
// shard modes.
|
|
func (x *Config) Mode() (m mode.Mode) {
|
|
s := config.StringSafe(
|
|
(*config.Config)(x),
|
|
"mode",
|
|
)
|
|
|
|
switch s {
|
|
case "read-write", "":
|
|
m = mode.ReadWrite
|
|
case "read-only":
|
|
m = mode.ReadOnly
|
|
case "degraded":
|
|
m = mode.Degraded
|
|
case "degraded-read-only":
|
|
m = mode.DegradedReadOnly
|
|
case "disabled":
|
|
m = mode.Disabled
|
|
default:
|
|
panic(fmt.Sprintf("unknown shard mode: %s", s))
|
|
}
|
|
|
|
return
|
|
}
|