services

Documentation

Index

• func AddTask(task chan []byte)
• func CheckNoReadyEx(task chan []byte)
• func PING(urls []string, path, ihost string)
• func StartWorkers(max int, task chan []byte)
• type AnswerData
• type JSONdata

Functions

func AddTask

func AddTask(task chan []byte)

Добавляет задание для ворекров которые были созданы в StartWorkers

func CheckNoReadyEx

func CheckNoReadyEx(task chan []byte)

Проверяет какие задание не выполнены и запускает их выполнение (Запускается при запуске агента)

func PING

func PING(urls []string, path, ihost string)

Говорит оркестратору, что сервер агент доступенн

func StartWorkers

func StartWorkers(max int, task chan []byte)

Запускает горутины(воркеры)

Types

type AnswerData

type AnswerData struct {
	Ex     string `json:"ex"`
	Answer string `json:"answer"`
	Err    string `json:"err"`
}

type JSONdata

type JSONdata struct {
	Id       string        `json:"id"`
	Task     string        `json:"task"`
	WaitTime time.Duration `json:"wait_time"`
}