shardconfig

Documentation

Index

• Constants
• type Config
  • func From(c *config.Config) *Config
  • func (x *Config) BlobStor() *blobstorconfig.Config
  • func (x *Config) Compress() bool
  • func (x *Config) EstimateCompressibility() bool
  • func (x *Config) EstimateCompressibilityThreshold() float64
  • func (x *Config) GC() *gcconfig.Config
  • func (x *Config) Metabase() *metabaseconfig.Config
  • func (x *Config) Mode() (m mode.Mode)
  • func (x *Config) Pilorama() *piloramaconfig.Config
  • func (x *Config) RefillMetabase() bool
  • func (x *Config) RefillMetabaseWorkersCount() int
  • func (x *Config) SmallSizeLimit() uint64
  • func (x *Config) UncompressableContentTypes() []string
  • func (x *Config) WriteCache() *writecacheconfig.Config

Constants

const (
	// SmallSizeLimitDefault is a default limit of small objects payload in bytes.
	SmallSizeLimitDefault                   = 1 << 20
	EstimateCompressibilityThresholdDefault = 0.1
	RefillMetabaseWorkersCountDefault       = 500
)

Types

type Config

type Config config.Config

Config is a wrapper over the config section which provides access to Shard configurations.

func From

func From(c *config.Config) *Config

From wraps config section into Config.

func (*Config) BlobStor

func (x *Config) BlobStor() *blobstorconfig.Config

BlobStor returns "blobstor" subsection as a blobstorconfig.Config.

func (*Config) Compress

func (x *Config) Compress() bool

Compress returns the value of "compress" config parameter.

Returns false if the value is not a valid bool.

func (*Config) EstimateCompressibility

func (x *Config) EstimateCompressibility() bool

EstimateCompressibility returns the value of "estimate_compressibility" config parameter.

Returns false if the value is not a valid bool.

func (*Config) EstimateCompressibilityThreshold

func (x *Config) EstimateCompressibilityThreshold() float64

EstimateCompressibilityThreshold returns the value of "estimate_compressibility_threshold" config parameter.

Returns EstimateCompressibilityThresholdDefault if the value is not defined, not valid float or not in range [0.0; 1.0].

func (*Config) GC

func (x *Config) GC() *gcconfig.Config

GC returns "gc" subsection as a gcconfig.Config.

func (*Config) Metabase

func (x *Config) Metabase() *metabaseconfig.Config

Metabase returns "metabase" subsection as a metabaseconfig.Config.

func (*Config) Mode

func (x *Config) Mode() (m mode.Mode)

Mode return the value of "mode" config parameter.

Panics if read the value is not one of predefined shard modes.

func (*Config) Pilorama

func (x *Config) Pilorama() *piloramaconfig.Config

Pilorama returns "pilorama" subsection as a piloramaconfig.Config.

func (*Config) RefillMetabase

func (x *Config) RefillMetabase() bool

RefillMetabase returns the value of "resync_metabase" config parameter.

Returns false if the value is not a valid bool.

func (*Config) RefillMetabaseWorkersCount

func (x *Config) RefillMetabaseWorkersCount() int

RefillMetabaseWorkersCount returns the value of "resync_metabase_worker_count" config parameter.

Returns RefillMetabaseWorkersCountDefault if the value is not a positive number.

func (*Config) SmallSizeLimit

func (x *Config) SmallSizeLimit() uint64

SmallSizeLimit returns the value of "small_object_size" config parameter.

Returns SmallSizeLimitDefault if the value is not a positive number.

func (*Config) UncompressableContentTypes

func (x *Config) UncompressableContentTypes() []string

UncompressableContentTypes returns the value of "compress_skip_content_types" config parameter.

Returns nil if a the value is missing or is invalid.

func (*Config) WriteCache

func (x *Config) WriteCache() *writecacheconfig.Config

WriteCache returns "writecache" subsection as a writecacheconfig.Config.