watcher

type Machine struct {
	// contains filtered or unexported fields
}

type MachineConfig struct {
	// Host хост, на котором машина ожидает подключения.
	Host string `yaml:"host"`
	// Post сервисный порт машины, который используется
	// для передачи команд от meta_node и возврата статистики выше.
	Port int `yaml:"port"`
	// Timeout время, по истечению которого в случае отсутствия ответа
	// машина признается не работающей и начинается процесс восстановления.
	Timeout util.Duration `yaml:"timeout"`
}

type MachineWatcher struct {
	// contains filtered or unexported fields
}

type MachineWatcherConfig struct {
	// Machines список доступных машин, которые будет опрашивать
	// machine_watcher и параметры подключения к ним.
	Machines []*MachineConfig `yaml:"machines"`
}

type NodeTelemetry struct {
	Name         string
	Action       string
	Address      string
	IsRunning    bool
	OldestOutput uint32
	PrevName     []string
}

type Plan struct {
	// contains filtered or unexported fields
}

type PlanConfig struct {
	PingFrequency util.Duration
	Retry         *util.RetryConfig
}

type PlanTelemetry struct {
	Name  string
	Nodes []*NodeTelemetry
}

type PlanWatcher struct {
	// contains filtered or unexported fields
}

type PlanWatcherConfig struct {
	// PingFrequency время между запросами к машинам для получения
	// информации о состоянии машин и запущенных на них рантаймов.
	PingFrequency util.Duration `yaml:"ping-freq"`
	// Retry конфигурация попток взаимодействия с узлом.
	Retry *util.RetryConfig `yaml:"retry"`
	// MachineWatcher набор настроек для watcher, который
	// следит за состоянием машин.
	MachineWatcher *MachineWatcherConfig `yaml:"machine-watcher"`
}