core

package
v0.0.0-...-31148e1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 15, 2021 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 на одной стадии одной задачи

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL