config

Documentation

Index

• Constants
• type ConfigurationMasterRunner
  • func ConfiureRunnerMaster() (*ConfigurationMasterRunner, error)
• type ConfigurationSlaveRunner
  • func ConfigureRunnerSlave() (*ConfigurationSlaveRunner, error)
• type ServiceConfig
  • func ConfigureService() (*ServiceConfig, error)
  • func (config *ServiceConfig) SetupNewPort(port int)

Constants

const (
	SERVICEMASTER = "MASTER"
	SERVICESLAVE  = "SLAVE"
)

const (
	PLUGINDEFAULT = "DEFAULT"
	PLUGINPORTAL  = "PORTAL"
)

Types

type ConfigurationMasterRunner

type ConfigurationMasterRunner struct {
	PathToLogsWork        string `cf_env:"LOGS_WORK_PATH" cf_default:"logs"`
	PathToReportsWork     string `cf_env:"REPORT_WORK_PATH" cf_default:"reports"`
	MaxTaskPerSlave       int    `cf_env:"MAX_TASKS_PER_SLAVE" cf_default:"10"`
	AgentID               string `cf_env:"AGENT_ID" cf_default:"default_agent"`
	AverageTimeoutPerTask int    `cf_env:"AVERAGE_TIMEOUT_PER_TASK"`
}

ConfigurationMasterRunner - все настройки по мастер ноде

func ConfiureRunnerMaster

func ConfiureRunnerMaster() (*ConfigurationMasterRunner, error)

ConfiureRunnerMaster - конфигурировании мастер ноды через Environment variables

type ConfigurationSlaveRunner

type ConfigurationSlaveRunner struct {
	AmountPullWorkers          int `cf_env:"AMOUNT_PULL_WORKERS" cf_default:"10"`
	AmountParallelTaskPerStage int `cf_env:"AMOUNT_PARALLEL_TASK_PER_STAGE" cf_default:"100"`
}

ConfigurationSlaveRunner - конфигурация слейв ноды

func ConfigureRunnerSlave

func ConfigureRunnerSlave() (*ConfigurationSlaveRunner, error)

ConfigureRunnerSlave - конфигурирования slave сервиса

type ServiceConfig

type ServiceConfig struct {
	APIPORT        int    `cf_env:"API_PORT" cf_default:"9999"`
	ConsulAddress  string `cf_env:"CONSUL_ADDRESS" cf_default:"127.0.0.1:8500"`
	ConsulUsername string `cf_env:"CONSUL_USERNAME" cf_default:"kubitre"`
	ConsulPassword string `cf_env:"CONSUL_PASSWORD" cf_default:"password"`
	ServiceType    string `cf_env:"SERVICE_TYPE" cf_default:"SLAVE"`     // MASTER, SLAVE
	ServicePlugin  string `cf_env:"SERVICE_PLUGIN" cf_default:"DEFAULT"` // DEFAULT, PORTAL
}

func ConfigureService

func ConfigureService() (*ServiceConfig, error)

ConfigureService - конфигурирование общих настроек для сервисов

func (*ServiceConfig) SetupNewPort

func (config *ServiceConfig) SetupNewPort(port int)

SetupNewPort - install port for binding