executor

Documentation

Index

• type Executor
  • func (e *Executor) Cancel(jobName string, id int) error
  • func (e *Executor) Execute(id int, job *model.Job) error
  • func (e *Executor) GetJobStatus(jobName string, jobID int) (model.Status, error)
• type ExecutorClient
  • func NewExecutorClient() *ExecutorClient
  • func (c *ExecutorClient) GetJobStatus(jobName string, jobID int) (model.Status, error)
  • func (c *ExecutorClient) GetStatusChangeChan() chan model.StatusChangeMessage
  • func (c *ExecutorClient) Main()
• type IExecutor

Types

type Executor

type Executor struct {
	StatusChan chan model.StatusChangeMessage
	// contains filtered or unexported fields
}

func (*Executor) Cancel

func (e *Executor) Cancel(jobName string, id int) error

Cancel 取消

func (*Executor) Execute

func (e *Executor) Execute(id int, job *model.Job) error

Execute 执行任务

func (*Executor) GetJobStatus

func (e *Executor) GetJobStatus(jobName string, jobID int) (model.Status, error)

type ExecutorClient

type ExecutorClient struct {
	QueueChan chan *model.QueueMessage
	// contains filtered or unexported fields
}

func NewExecutorClient

func NewExecutorClient() *ExecutorClient

func (*ExecutorClient) GetJobStatus

func (c *ExecutorClient) GetJobStatus(jobName string, jobID int) (model.Status, error)

func (*ExecutorClient) GetStatusChangeChan

func (c *ExecutorClient) GetStatusChangeChan() chan model.StatusChangeMessage

func (*ExecutorClient) Main

func (c *ExecutorClient) Main()

type IExecutor

type IExecutor interface {
	// Execute 执行任务
	Execute(id int, job *model.Job) error
	//SendResultToQueue 发送结果到队列
	// SendResultToQueue(job *model.JobDetail)
	Cancel(id int, job *model.Job) error
}