core

Documentation

Index

• type MasterRunnerCore
  • func InitNewMasterRunnerCore(config *config.ConfigurationMasterRunner, configService *config.ServiceConfig) (*MasterRunnerCore, error)
  • func (core *MasterRunnerCore) Run()
  • func (core *MasterRunnerCore) UnregisterService()
• type SlaveRunnerCore
  • func NewCoreSlaveRunner(config *config.ConfigurationSlaveRunner, configService *config.ServiceConfig) (*SlaveRunnerCore, error)
  • func (core *SlaveRunnerCore) CreatePipeline(taskConfig *models.TaskConfig) error
  • func (core *SlaveRunnerCore) RunWorkers()
  • func (core *SlaveRunnerCore) SetupConfigurationPipeline(config *models.TaskConfig) error
  • func (core *SlaveRunnerCore) UnregisterService()
• type WorkJob
• type Worker

Types

type MasterRunnerCore

type MasterRunnerCore struct {
	Discovery     *discovery.Discovery
	SlaveMoniring *monitor.SlaveMonitoring
}

MasterRunnerCore - ядро master ноды

func InitNewMasterRunnerCore

func InitNewMasterRunnerCore(config *config.ConfigurationMasterRunner,
	configService *config.ServiceConfig,
) (*MasterRunnerCore, error)

InitNewMasterRunnerCore - инициализация ядра текущего сервиса

func (*MasterRunnerCore) Run

func (core *MasterRunnerCore) Run()

Run - запуск роутера, discovery, получение информации о слейвах

func (*MasterRunnerCore) UnregisterService

func (core *MasterRunnerCore) UnregisterService()

UnregisterService - де регистрация сервиса из consul

type SlaveRunnerCore

type SlaveRunnerCore struct {
	Git          *gitmod.Git
	Docker       *docker_runner.DockerExecutor
	WorkerPull   chan models.TaskConfig
	ChannelClose chan string
	SlaveConfig  *config.ConfigurationSlaveRunner
	Discovery    *discovery.Discovery
}

SlaveRunnerCore - ядро для слейва

func NewCoreSlaveRunner

func NewCoreSlaveRunner(
	config *config.ConfigurationSlaveRunner,
	configService *config.ServiceConfig,
) (*SlaveRunnerCore, error)

NewCoreSlaveRunner - инициализация нового ядра слейв модуля

func (*SlaveRunnerCore) CreatePipeline

func (core *SlaveRunnerCore) CreatePipeline(taskConfig *models.TaskConfig) error

CreatePipeline - создание пайплайна на выполнение одной задачи

func (*SlaveRunnerCore) RunWorkers

func (core *SlaveRunnerCore) RunWorkers()

RunWorkers - запуск пула воркеров

func (*SlaveRunnerCore) SetupConfigurationPipeline

func (core *SlaveRunnerCore) SetupConfigurationPipeline(config *models.TaskConfig) error

SetupConfigurationPipeline - setting up configuration if its no configuring in start NOW USING ONLY FOR TESTING

func (*SlaveRunnerCore) UnregisterService

func (core *SlaveRunnerCore) UnregisterService()

UnregisterService - деаутентификация сервиса в консуле

type WorkJob

type WorkJob struct {
	JobName    string
	Stage      string
	TaskID     string
	JobStatus  int
	JobResukt  models.LogsPerTask
	JobReports models.ReportPerTask
	JobMetrics map[string]string
}

WorkJob - статус по задаче

type Worker

type Worker struct {
	Task   chan models.Job         // текущая задача у воркера
	Result chan models.LogsPerTask // текущий результат у воркера (лог файл)
}

Worker - единичная воркер функция, которая отвечает за выполнение всех job на одной стадии одной задачи