config

Documentation

Index

• func LoadWorkerConfFromEnv(prefix string) (interface{}, error)
• type CommonConfig
  • func (cc *CommonConfig) Logger() *logrus.Logger
• type MasterEnv
• type WorkerEnv

Functions

func LoadWorkerConfFromEnv

func LoadWorkerConfFromEnv(prefix string) (interface{}, error)

LoadWorkerConfFromEnv reads configuration from env TODO: validate

Types

type CommonConfig

type CommonConfig struct {
	LogLevel string `envconfig:"LOG_LEVEL" default:"INFO" yaml:"log_level"`
}

CommonConfig is set of environments for both of worker and master

func (*CommonConfig) Logger

func (cc *CommonConfig) Logger() *logrus.Logger

Logger returns logger

type MasterEnv

type MasterEnv struct {
	CommonConfig
	ListenAddress   string   `envconfig:"LISTEN_ADDR" default:"127.0.0.1:8801" yaml:"listen_addr"`
	APIPort         int      `envconfig:"API_PORT" default:":8881" yaml:"api_port"`
	WorkerAddresses []string `envconfig:"WORKERS" default:"" yaml:"worker_addresses"`
	Partitions      uint64   `envconfig:"PARTITIONS" yaml:"partitions"`
}

MasterEnv is set of environments for workers

type WorkerEnv

type WorkerEnv struct {
	CommonConfig
	ListenAddress string `envconfig:"LISTEN_ADDR" default:"127.0.0.1:8802" yaml:"listen_addr"`
}

WorkerEnv is set of environments for workers