executor

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

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

type IExecutor interface {

	// FetchJob 获取任务
	FetchJob(name string) (io.Reader, error)

	// Execute 执行任务
	Execute(id int, job *model2.Job) error

	// HandlerLog 处理日志
	HandlerLog(jobId int)

	//SendResultToQueue 发送结果到队列
	SendResultToQueue(channel chan model2.StatusChangeMessage, jobWrapper *model2.JobDetail)

	Cancel(id int, job *model2.Job) error
}