executor

Documentation

Index

• type ExecResponse
  • func (er ExecResponse) String() string
• type IJobExecutor
  • func NewJobExecutor(cfg *setting.Cfg) IJobExecutor
• type JobExecutor
  • func (j *JobExecutor) RunGoFunc(task *models.TaskDto) (ExecResponse, error)
  • func (*JobExecutor) RunHttpRequest(task *models.TaskDto) (ExecResponse, error)
  • func (j *JobExecutor) RunShellJob(task *models.TaskDto) (ExecResponse, error)

Types

type ExecResponse

type ExecResponse struct {
	Code   int
	Result []byte
}

func (ExecResponse) String

func (er ExecResponse) String() string

type IJobExecutor

type IJobExecutor interface {
	RunShellJob(task *models.TaskDto) (ExecResponse, error)
	RunGoFunc(task *models.TaskDto) (ExecResponse, error)
	RunHttpRequest(task *models.TaskDto) (ExecResponse, error)
}

func NewJobExecutor

func NewJobExecutor(cfg *setting.Cfg) IJobExecutor

type JobExecutor

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

func (*JobExecutor) RunGoFunc

func (j *JobExecutor) RunGoFunc(task *models.TaskDto) (ExecResponse, error)

RunGoFunc implements IJobExecutor

func (*JobExecutor) RunHttpRequest

func (*JobExecutor) RunHttpRequest(task *models.TaskDto) (ExecResponse, error)

RunHttpRequest implements IJobExecutor

func (*JobExecutor) RunShellJob

func (j *JobExecutor) RunShellJob(task *models.TaskDto) (ExecResponse, error)

RunShellJob implements IJobExecutor