Documentation
¶
Index ¶
- type MasterRunnerService
- func (service *MasterRunnerService) ChangeStatusJob(statusTaskChangePayload *payloads.ChangeStatusJob, request *http.Request, ...)
- func (service *MasterRunnerService) ChangeStatusTask(statusTaskChangePayload *payloads.ChangeStatusTask, request *http.Request, ...)
- func (service *MasterRunnerService) CreateLogTask(request *http.Request, writer http.ResponseWriter)
- func (service *MasterRunnerService) CreateReportsPerTask(request *http.Request, writer http.ResponseWriter)
- func (service *MasterRunnerService) GetAgentID() string
- func (service *MasterRunnerService) GetCore() *core.MasterRunnerCore
- func (service *MasterRunnerService) GetLogsPerTask(request *http.Request, writer http.ResponseWriter, taskID, stage, job string)
- func (service *MasterRunnerService) GetReportPath() string
- func (service *MasterRunnerService) GetReportPerTask(request *http.Request, writer http.ResponseWriter) map[string][]string
- func (service *MasterRunnerService) GetReportsForStatus(taskID, fileName string) (map[string][]string, error)
- func (service *MasterRunnerService) GetReportsTask(taskID string) (map[string][]string, error)
- func (service *MasterRunnerService) GetStatusWorkers(request *http.Request, writer http.ResponseWriter)
- func (service *MasterRunnerService) GetTaskStatus(request *http.Request, writer http.ResponseWriter, taskID string) *models.Task
- func (service *MasterRunnerService) NewTask(taskConfig *models.TaskConfig, request *http.Request, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MasterRunnerService ¶
type MasterRunnerService struct {
// contains filtered or unexported fields
}
MasterRunnerService - сервис исполняющего модуля в режиме мастер
func InitializeMasterRunnerService ¶
func InitializeMasterRunnerService(configService *config.ServiceConfig, masterConfig *config.ConfigurationMasterRunner) (*MasterRunnerService, error)
InitializeMasterRunnerService - инициализация сервиса исполняющего модуля в режиме мастер
func (*MasterRunnerService) ChangeStatusJob ¶
func (service *MasterRunnerService) ChangeStatusJob(statusTaskChangePayload *payloads.ChangeStatusJob, request *http.Request, writer http.ResponseWriter)
ChangeStatusJob - изменение статуса джобы
func (*MasterRunnerService) ChangeStatusTask ¶
func (service *MasterRunnerService) ChangeStatusTask(statusTaskChangePayload *payloads.ChangeStatusTask, request *http.Request, writer http.ResponseWriter)
ChangeStatusTask - изменить статус задачи
func (*MasterRunnerService) CreateLogTask ¶
func (service *MasterRunnerService) CreateLogTask(request *http.Request, writer http.ResponseWriter)
CreateLogTask - закрытый метод разрешённый только для воркеров. Создание логов по задаче (по каждой конкретной job)
func (*MasterRunnerService) CreateReportsPerTask ¶
func (service *MasterRunnerService) CreateReportsPerTask(request *http.Request, writer http.ResponseWriter)
CreateReportsPerTask - запись отчётов по задаче
func (*MasterRunnerService) GetAgentID ¶
func (service *MasterRunnerService) GetAgentID() string
GetAgentID - получение текущего идентификатора агента
func (*MasterRunnerService) GetCore ¶
func (service *MasterRunnerService) GetCore() *core.MasterRunnerCore
GetCore - отдать текущее ядро
func (*MasterRunnerService) GetLogsPerTask ¶
func (service *MasterRunnerService) GetLogsPerTask(request *http.Request, writer http.ResponseWriter, taskID, stage, job string)
GetLogsPerTask - получение логов по задаче (в случае если будет передан только taskID мержатся все логи из задачи, если будет taskID и stage - тогда только логи по стади и таске ну и по job в случае передачи taskID, stage, job)
func (*MasterRunnerService) GetReportPath ¶
func (service *MasterRunnerService) GetReportPath() string
GetReportPath - получить путь до текущих отчётов
func (*MasterRunnerService) GetReportPerTask ¶
func (service *MasterRunnerService) GetReportPerTask(request *http.Request, writer http.ResponseWriter) map[string][]string
GetReportPerTask - получение отчёта по задаче (в случае, если в задаче использовались extra параметры, для выделения каких-либо метрик и т.д.)
func (*MasterRunnerService) GetReportsForStatus ¶
func (service *MasterRunnerService) GetReportsForStatus(taskID, fileName string) (map[string][]string, error)
func (*MasterRunnerService) GetReportsTask ¶
func (service *MasterRunnerService) GetReportsTask(taskID string) (map[string][]string, error)
func (*MasterRunnerService) GetStatusWorkers ¶
func (service *MasterRunnerService) GetStatusWorkers(request *http.Request, writer http.ResponseWriter)
GetStatusWorkers - получение текущего состояния всех воркеров
func (*MasterRunnerService) GetTaskStatus ¶
func (service *MasterRunnerService) GetTaskStatus(request *http.Request, writer http.ResponseWriter, taskID string) *models.Task
GetTaskStatus - получить статус задачи по её идентификатору
func (*MasterRunnerService) NewTask ¶
func (service *MasterRunnerService) NewTask(taskConfig *models.TaskConfig, request *http.Request, writer http.ResponseWriter)
NewTask - создание задачи
Source Files