driver

type CoreHandler struct {
	ICoreHandler
}

type CoreHandlerFunc func(core *ExecCore, state int, err error)

type Driver struct {
	sync.RWMutex
	CoreHandler
	Root string
	// contains filtered or unexported fields
}

type DriverContext struct {
	Job       *Job
	StdOut    string
	ErrOut    string
	ExecErr   string
	ExecAt    time.Time
	NextAt    time.Time
	ExecTimes float64
}

type DriverExecuteHandlerFunc func(state int, context *DriverContext)

type DriverSelectHandlerFunc func(context *DriverContext)

type DriverStopedHandlerFunc func(state int, context *DriverContext)

type ExecCore struct {
	JobId      string           //任务编号
	WorkDir    string           //工作目录
	Exit       ExitState        //退出状态
	ExecAt     time.Time        //本次执行时间
	NextAt     time.Time        //下次执行时间
	Schedule   *models.Schedule //执行计划
	ExecDriver *ExecDriver      //执行驱动
	// contains filtered or unexported fields
}

type ExecDriver struct {
	Running   bool      //执行状态
	Command   *exec.Cmd //执行对象
	ExecTimes float64   //总执行时长
	StdOut    StdOutput //标准输出
	ErrOut    StdOutput //错误输出
}

type ExitState int

type ICoreHandler interface {
	OnCoreHandlerFunc(core *ExecCore, state int, err error)
}

type IDriverHandler interface {
	//DriverContext Code = ERR_SCHEDULE_EXECUTE
	OnDriverExecuteHandlerFunc(state int, context *DriverContext)
	//DriverContext Code = ERR_SCHEDULE_INVALID
	OnDriverSelectHandlerFunc(context *DriverContext)
	//DriverContext Code = ERR_SCHEDULE_STOPED
	OnDriverStopedHandlerFunc(state int, context *DriverContext)
}

type IExecDriver interface {
	//启动任务
	Start(start chan<- bool) error
	//停止任务
	Stop() error
	//设置exec.cmd输入输出管道
	SetCommandPipe() error
	//读取exec.cmd管道数据
	ReadCommandPipeBuffer(stdoutCh chan<- []byte, erroutCh chan<- []byte)
}

type Job struct {
	JobId      string    //任务编号
	Name       string    //任务名称
	Root       string    //工作根目录
	FileCode   string    //文件编码
	WorkDir    string    //工作目录
	Cmd        string    //执行命令
	Env        []string  //环境变量
	Timeout    int       //执行超时(秒)
	ExecMaxSec int64     //执行最长时长(时间戳：UNIX时间戳)
	State      JobState  //执行状态
	LastExecAt time.Time //最后一次执行时间
	LastError  error     //最后一次错误信息
	// contains filtered or unexported fields
}

type JobState int

type StdOutput struct {
	Reader io.ReadCloser //输出读取对象(stdout或stderr)
	Buffer []byte        //输出数据
}