config

Documentation

Index

• type Config
  • func (c *Config) PrintUsage()
  • func (c *Config) PrintVersion()
• type GRPC
• type HTTP
• type MessagesFSMConfig
• type MetadataFSMConfig
• type RaftConfig

Types

type Config

type Config struct {
	MetadataPath   string      `mapstructure:"metadata_path"`
	PartitionsPath string      `mapstructure:"partitions_path"`
	RaftConfig     *RaftConfig `mapstructure:"raft"`

	ShardLeaderWaitTime           time.Duration `mapstructure:"shard_leader_wait_time"`
	ShardLeaderSetReCheckInterval time.Duration `mapstructure:"shard_leader_set_recheck_interval"`
	ConsumerLostTime              time.Duration `mapstructure:"consumer_lost_time"`
	ConsumerHealthCheckInterval   time.Duration `mapstructure:"consumer_health_check_interval"`
	ShutdownTimeout               time.Duration `mapstructure:"shutdown_timeout"`
	Level                         logger.Level  `mapstructure:"level"`

	GRPC    GRPC `mapstructure:"grpc"`
	HTTP    HTTP `mapstructure:"http"`
	Version bool `mapstructure:"version"`
	Help    bool `mapstructure:"help"`
}

var (
	Conf *Config
)

func (*Config) PrintUsage

func (c *Config) PrintUsage()

func (*Config) PrintVersion

func (c *Config) PrintVersion()

type GRPC

type GRPC struct {
	ListenerAddr string `mapstructure:"listener_addr"`
}

type HTTP

type HTTP struct {
	ListenerAddr string `mapstructure:"listener_addr"`
}

type MessagesFSMConfig

type MessagesFSMConfig struct {
	SnapshotsEntries   uint64 `mapstructure:"snapshot_entries"`
	CompactionOverhead uint64 `mapstructure:"compaction_overhead"`
}

type MetadataFSMConfig

type MetadataFSMConfig struct {
	SnapshotEntries    uint64 `mapstructure:"snapshot_entries"`
	CompactionOverhead uint64 `mapstructure:"compaction_overhead"`
}

type RaftConfig

type RaftConfig struct {
	ReplicaID     uint64            `mapstructure:"replica_id"`
	Addr          string            `mapstructure:"addr"`
	Join          bool              `mapstructure:"join"`
	InviteMembers map[uint64]string `mapstructure:"invite_members"`
	LogsDataDir   string            `mapstructure:"logs_data_dir"`
	Metadata      MetadataFSMConfig `mapstructure:"metadata_fsm"`
	Messages      MessagesFSMConfig `mapstructure:"messages_fsm"`
}