job_run

Documentation

Index

• Constants
• type JobRun
  • func NewJobRun(models *model.Models, kubeClient *cluster.KubeClient, ...) *JobRun
  • func (b *JobRun) Cancel(jobId uint) error
  • func (b *JobRun) Execute(jobId uint, pluginKey string, params map[string]interface{}) (resp *utils.Response)
• type PluginLogger
  • func NewPluginLogger(models *model.Models, jobId uint) *PluginLogger
  • func (l *PluginLogger) Close() error
  • func (l *PluginLogger) FlushLogToDB()
  • func (l *PluginLogger) Log(format string, a ...interface{})
  • func (l *PluginLogger) Reset(format string, a ...interface{})
• type SpaceletJob
  • func (s SpaceletJob) Executor(params *plugins.ExecutorParams) (plugins.Executor, error)

Constants

const SpaceletJobStatusInterval = time.Second * 5

Types

type JobRun

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

JobRun pipeline controller流水线任务执行处理

func NewJobRun

func NewJobRun(models *model.Models, kubeClient *cluster.KubeClient, informerFactory informer.Factory) *JobRun

func (*JobRun) Cancel

func (b *JobRun) Cancel(jobId uint) error

func (*JobRun) Execute

func (b *JobRun) Execute(jobId uint, pluginKey string, params map[string]interface{}) (resp *utils.Response)

type PluginLogger

type PluginLogger struct {
	*bytes.Buffer
	// contains filtered or unexported fields
}

PluginLogger 记录日志到数据库

func NewPluginLogger

func NewPluginLogger(models *model.Models, jobId uint) *PluginLogger

func (*PluginLogger) Close

func (l *PluginLogger) Close() error

func (*PluginLogger) FlushLogToDB

func (l *PluginLogger) FlushLogToDB()

FlushLogToDB 定时刷新日志到数据库

func (*PluginLogger) Log

func (l *PluginLogger) Log(format string, a ...interface{})

func (*PluginLogger) Reset

func (l *PluginLogger) Reset(format string, a ...interface{})

type SpaceletJob

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

SpaceletJob spacelet节点执行pipeline job

func (SpaceletJob) Executor

func (s SpaceletJob) Executor(params *plugins.ExecutorParams) (plugins.Executor, error)

Executor 创建一个spaceletJob执行器，通过调用spacelet执行pipeline接口执行任务