xxl

type AddJobInfo struct {
	JobGroupID             int                       `json:"jobGroup"`               //任务组id
	JobDesc                string                    `json:"jobDesc"`                //任务描述
	ExecutorRouteStrategy  ExecutorRouteStrategyType `json:"executorRouteStrategy"`  //执行策略
	CronGenDisplay         string                    `json:"cronGen_display"`        //crontab表达式
	JobCron                string                    `json:"jobCron"`                //crontab表达式
	ChildJobId             string                    `json:"childJobId"`             //子任务id
	Author                 string                    `json:"author"`                 //责任人
	AlarmEmail             string                    `json:"alarmEmail"`             //提醒邮件
	ExecutorHandler        string                    `json:"executorHandler"`        //任务标识
	ExecutorParams         string                    `json:"executorParam"`          // 任务参数
	ExecutorBlockStrategy  ExecutorBlockStrategy     `json:"executorBlockStrategy"`  // 任务阻塞策略
	ExecutorTimeout        int64                     `json:"executorTimeout"`        // 任务超时时间，单位秒，大于零时生效
	ExecutorFailRetryCount int64                     `json:"executorFailRetryCount"` // 任务超时重试次数
	GlueType               string                    `json:"glueType"`               // 任务模式，可选值参考 com.xxl.job.core.glue.GlueTypeEnum
	GlueSource             string                    `json:"glueSource"`             // GLUE脚本代码
	GlueRemark             string                    `json:"glueRemark"`             // GLUE脚本标注
}

type ExecuteResult struct {
	Code int64       `json:"code"`
	Msg  interface{} `json:"msg"`
}

type Executor interface {
	//初始化
	Init(...Option)
	//日志查询
	LogHandler(handler LogHandler)
	//注册任务
	RegTask(pattern string, task TaskFunc)
	//运行任务
	RunTask(writer http.ResponseWriter, request *http.Request)
	//杀死任务
	KillTask(writer http.ResponseWriter, request *http.Request)
	//任务日志
	TaskLog(writer http.ResponseWriter, request *http.Request)
	//运行服务
	Run() error
	//动态增加一个任务
	AddJob(taskInfo AddJobInfo) ([]byte, error)
}

type ExecutorBlockStrategy string

type ExecutorRouteStrategyType string

type LogFunc func(req LogReq, res *LogRes) []byte

type LogHandler func(req *LogReq) *LogRes

type LogReq struct {
	LogDateTim  int64 `json:"logDateTim"`  // 本次调度日志时间
	LogID       int64 `json:"logId"`       // 本次调度日志ID
	FromLineNum int   `json:"fromLineNum"` // 日志开始行号，滚动加载日志
}

type LogRes struct {
	Code    int64         `json:"code"`    // 200 表示正常、其他失败
	Msg     string        `json:"msg"`     // 错误提示消息
	Content LogResContent `json:"content"` // 日志响应内容
}

type LogResContent struct {
	FromLineNum int    `json:"fromLineNum"` // 本次请求，日志开始行数
	ToLineNum   int    `json:"toLineNum"`   // 本次请求，日志结束行号
	LogContent  string `json:"logContent"`  // 本次请求日志内容
	IsEnd       bool   `json:"isEnd"`       // 日志是否全部加载完
}

type Logger interface {
	Info(format string, a ...interface{})
	Error(format string, a ...interface{})
}

type Option func(o *Options)

type Options struct {
	ServerAddr   string        `json:"server_addr"`   //调度中心地址
	AccessToken  string        `json:"access_token"`  //请求令牌
	Timeout      time.Duration `json:"timeout"`       //接口超时时间
	ExecutorIp   string        `json:"executor_ip"`   //本地(执行器)IP(可自行获取)
	ExecutorPort string        `json:"executor_port"` //本地(执行器)端口
	RegistryKey  string        `json:"registry_key"`  //执行器名称
	LogDir       string        `json:"log_dir"`       //日志目录
	// contains filtered or unexported fields
}

type Registry struct {
	RegistryGroup string `json:"registryGroup"`
	RegistryKey   string `json:"registryKey"`
	RegistryValue string `json:"registryValue"`
	AccessToken   string `json:"accessToken"`
}

type RespAddJob struct {
	Code    int    `json:"code"`
	Msg     string `json:"msg"`
	Content string `json:"content"`
}

type RunReq struct {
	JobID                 int64  `json:"jobId"`                 // 任务ID
	ExecutorHandler       string `json:"executorHandler"`       // 任务标识
	ExecutorParams        string `json:"executorParams"`        // 任务参数
	ExecutorBlockStrategy string `json:"executorBlockStrategy"` // 任务阻塞策略
	ExecutorTimeout       int64  `json:"executorTimeout"`       // 任务超时时间，单位秒，大于零时生效
	LogID                 int64  `json:"logId"`                 // 本次调度日志ID
	LogDateTime           int64  `json:"logDateTime"`           // 本次调度日志时间
	GlueType              string `json:"glueType"`              // 任务模式，可选值参考 com.xxl.job.core.glue.GlueTypeEnum
	GlueSource            string `json:"glueSource"`            // GLUE脚本代码
	GlueUpdatetime        int64  `json:"glueUpdatetime"`        // GLUE脚本更新时间，用于判定脚本是否变更以及是否需要刷新
	BroadcastIndex        int64  `json:"broadcastIndex"`        // 分片参数：当前分片
	BroadcastTotal        int64  `json:"broadcastTotal"`        // 分片参数：总分片
}

type Task struct {
	Id    int64
	Name  string
	Ext   context.Context
	Param *RunReq

	Cancel    context.CancelFunc
	StartTime int64
	EndTime   int64
	// contains filtered or unexported fields
}

type TaskFunc func(cxt context.Context, param *RunReq) string