engineconfig

Documentation

Index

• Constants
• Variables
• func IterateShards(c *config.Config, required bool, f func(*shardconfig.Config) error) error
• func ShardErrorThreshold(c *config.Config) uint32
• func ShardPoolSize(c *config.Config) uint32

Constants

const (

	// ShardPoolSizeDefault is a default value of routine pool size per-shard to
	// process object PUT operations in a storage engine.
	ShardPoolSizeDefault = 20
)

Variables

var ErrNoShardConfigured = errors.New("no shard configured")

ErrNoShardConfigured is returned when at least 1 shard is required but none are found.

Functions

func IterateShards

func IterateShards(c *config.Config, required bool, f func(*shardconfig.Config) error) error

IterateShards iterates over subsections of "shard" subsection of "storage" section of c, wrap them into shardconfig.Config and passes to f.

Section names are expected to be consecutive integer numbers, starting from 0.

Panics if N is not a positive number while shards are required.

func ShardErrorThreshold

func ShardErrorThreshold(c *config.Config) uint32

ShardErrorThreshold returns the value of "shard_ro_error_threshold" config parameter from "storage" section.

Returns 0 if the the value is missing.

func ShardPoolSize

func ShardPoolSize(c *config.Config) uint32

ShardPoolSize returns the value of "shard_pool_size" config parameter from "storage" section.

Returns ShardPoolSizeDefault if the value is not a positive number.