forked from TrueCloudLab/frostfs-node
[#1764] neofs-node: Use constants for storage types
Signed-off-by: Evgenii Stratonikov <evgeniy@morphbits.ru>
This commit is contained in:
parent
9113793688
commit
6f45cc81fc
6 changed files with 16 additions and 7 deletions
|
@ -446,7 +446,7 @@ func initShardOptions(c *cfg) {
|
||||||
var st []blobstor.SubStorage
|
var st []blobstor.SubStorage
|
||||||
for i := range storages {
|
for i := range storages {
|
||||||
switch storages[i].Type() {
|
switch storages[i].Type() {
|
||||||
case "blobovnicza":
|
case blobovniczatree.Type:
|
||||||
sub := blobovniczaconfig.From((*config.Config)(storages[i]))
|
sub := blobovniczaconfig.From((*config.Config)(storages[i]))
|
||||||
lim := sc.SmallSizeLimit()
|
lim := sc.SmallSizeLimit()
|
||||||
st = append(st, blobstor.SubStorage{
|
st = append(st, blobstor.SubStorage{
|
||||||
|
@ -462,7 +462,7 @@ func initShardOptions(c *cfg) {
|
||||||
return uint64(len(data)) < lim
|
return uint64(len(data)) < lim
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
case "fstree":
|
case fstree.Type:
|
||||||
sub := fstreeconfig.From((*config.Config)(storages[i]))
|
sub := fstreeconfig.From((*config.Config)(storages[i]))
|
||||||
st = append(st, blobstor.SubStorage{
|
st = append(st, blobstor.SubStorage{
|
||||||
Storage: fstree.New(
|
Storage: fstree.New(
|
||||||
|
|
|
@ -3,6 +3,7 @@ package blobovniczaconfig
|
||||||
import (
|
import (
|
||||||
"github.com/nspcc-dev/neofs-node/cmd/neofs-node/config"
|
"github.com/nspcc-dev/neofs-node/cmd/neofs-node/config"
|
||||||
boltdbconfig "github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/engine/shard/boltdb"
|
boltdbconfig "github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/engine/shard/boltdb"
|
||||||
|
"github.com/nspcc-dev/neofs-node/pkg/local_object_storage/blobstor/blobovniczatree"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Config is a wrapper over the config section
|
// Config is a wrapper over the config section
|
||||||
|
@ -31,7 +32,7 @@ func From(c *config.Config) *Config {
|
||||||
|
|
||||||
// Type returns the storage type.
|
// Type returns the storage type.
|
||||||
func (x *Config) Type() string {
|
func (x *Config) Type() string {
|
||||||
return "blobovnicza"
|
return blobovniczatree.Type
|
||||||
}
|
}
|
||||||
|
|
||||||
// Size returns the value of "size" config parameter.
|
// Size returns the value of "size" config parameter.
|
||||||
|
|
|
@ -5,6 +5,8 @@ import (
|
||||||
|
|
||||||
"github.com/nspcc-dev/neofs-node/cmd/neofs-node/config"
|
"github.com/nspcc-dev/neofs-node/cmd/neofs-node/config"
|
||||||
"github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/engine/shard/blobstor/storage"
|
"github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/engine/shard/blobstor/storage"
|
||||||
|
"github.com/nspcc-dev/neofs-node/pkg/local_object_storage/blobstor/blobovniczatree"
|
||||||
|
"github.com/nspcc-dev/neofs-node/pkg/local_object_storage/blobstor/fstree"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Config is a wrapper over the config section
|
// Config is a wrapper over the config section
|
||||||
|
@ -26,7 +28,7 @@ func (x *Config) Storages() []*storage.Config {
|
||||||
switch typ {
|
switch typ {
|
||||||
case "":
|
case "":
|
||||||
return ss
|
return ss
|
||||||
case "fstree", "blobovnicza":
|
case fstree.Type, blobovniczatree.Type:
|
||||||
sub := storage.From((*config.Config)(x).Sub(strconv.Itoa(i)))
|
sub := storage.From((*config.Config)(x).Sub(strconv.Itoa(i)))
|
||||||
ss = append(ss, sub)
|
ss = append(ss, sub)
|
||||||
default:
|
default:
|
||||||
|
|
|
@ -19,7 +19,7 @@ func From(c *config.Config) *Config {
|
||||||
|
|
||||||
// Type returns the storage type.
|
// Type returns the storage type.
|
||||||
func (x *Config) Type() string {
|
func (x *Config) Type() string {
|
||||||
return "fstree"
|
return fstree.Type
|
||||||
}
|
}
|
||||||
|
|
||||||
// Depth returns the value of "depth" config parameter.
|
// Depth returns the value of "depth" config parameter.
|
||||||
|
|
|
@ -229,9 +229,12 @@ func u64FromHexString(str string) uint64 {
|
||||||
return v
|
return v
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Type is blobovniczatree storage type used in logs and configuration.
|
||||||
|
const Type = "blobovnicza"
|
||||||
|
|
||||||
// Type implements common.Storage.
|
// Type implements common.Storage.
|
||||||
func (b *Blobovniczas) Type() string {
|
func (b *Blobovniczas) Type() string {
|
||||||
return "blobovnicza"
|
return Type
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetCompressor implements common.Storage.
|
// SetCompressor implements common.Storage.
|
||||||
|
|
|
@ -330,9 +330,12 @@ func (t *FSTree) NumberOfObjects() (uint64, error) {
|
||||||
return counter, nil
|
return counter, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Type is fstree storage type used in logs and configuration.
|
||||||
|
const Type = "fstree"
|
||||||
|
|
||||||
// Type implements common.Storage.
|
// Type implements common.Storage.
|
||||||
func (*FSTree) Type() string {
|
func (*FSTree) Type() string {
|
||||||
return "fstree"
|
return Type
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetCompressor implements common.Storage.
|
// SetCompressor implements common.Storage.
|
||||||
|
|
Loading…
Reference in a new issue