engine

package module

v1.0.2 Latest Latest Go to latest Published: Feb 1, 2023 License: GPL-3.0 Imports: 6 Imported by: 4

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewEngine() *Engine

func (e *Engine) CreateJob(name string, yaml string) error

func (e *Engine) DeleteJob(name string) error

func (e *Engine) DeleteJobHistory(name string, historyId int) error

func (e *Engine) ExecuteJob(name string) (*model.JobDetail, error)

func (e *Engine) GetCodeInfo(name string, historyId int) string

func (e *Engine) GetJob(name string) *model.Job

func (e *Engine) GetJobHistory(name string, historyId int) *model.JobDetail

func (e *Engine) GetJobHistoryLog(name string, historyId int) *model.JobLog

func (e *Engine) GetJobHistoryStageLog(name string, historyId int, stageName string, start int) *model.JobStageLog

func (e *Engine) GetJobHistorys(name string, page, size int) *model.JobDetailPage

func (e *Engine) GetJobs(keyword string, page int, size int) *model.JobPage

func (e *Engine) ReExecuteJob(name string, historyId int) error

func (e *Engine) RegisterStatusChangeHook(hookResult func(message model.StatusChangeMessage))

func (e *Engine) Start()

func (e *Engine) TerminalJob(name string, historyId int) error

func (e *Engine) UpdateJob(name, newName, jobYaml string) error

Path	Synopsis
action
consts
dispatcher
executor
grpc
api
client
server
logger logger 提供封装好的 logrus 日志库日志等级从底到高分别为：trace, debug, info, warn, error, fatal, panic trace 用于跟踪程序运行过程中的一些细节 debug 用于调试程序 info 用于重要信息 warn 用于警告信息 error 用于错误信息 fatal 用于致命错误，程序将退出 panic 用于致命错误，程序将崩溃退出，并展开堆栈调用信息	logger 提供封装好的 logrus 日志库日志等级从底到高分别为：trace, debug, info, warn, error, fatal, panic trace 用于跟踪程序运行过程中的一些细节 debug 用于调试程序 info 用于重要信息 warn 用于警告信息 error 用于错误信息 fatal 用于致命错误，程序将退出 panic 用于致命错误，程序将崩溃退出，并展开堆栈调用信息
model
output
pipeline
queue
service
utils
platform