forked from xxl-job/xxl-job-executor-go
-
Notifications
You must be signed in to change notification settings - Fork 0
/
dto.go
91 lines (77 loc) · 3.45 KB
/
dto.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
package xxl
//通用响应
type res struct {
Code int64 `json:"code"` // 200 表示正常、其他失败
Msg interface{} `json:"msg"` // 错误提示消息
}
/***************** 上行参数 *********************/
// Registry 注册参数
type Registry struct {
RegistryGroup string `json:"registryGroup"`
RegistryKey string `json:"registryKey"`
RegistryValue string `json:"registryValue"`
}
//执行器执行完任务后,回调任务结果时使用
type call []*callElement
type callElement struct {
LogID int64 `json:"logId"`
LogDateTim int64 `json:"logDateTim"`
ExecuteResult *ExecuteResult `json:"executeResult"`
//以下是7.31版本 v2.3.0 Release所使用的字段
HandleCode int `json:"handleCode"` //200表示正常,500表示失败
HandleMsg string `json:"handleMsg"`
}
// ExecuteResult 任务执行结果 200 表示任务执行正常,500表示失败
type ExecuteResult struct {
Code int64 `json:"code"`
Msg interface{} `json:"msg"`
}
/***************** 下行参数 *********************/
//阻塞处理策略
const (
serialExecution = "SERIAL_EXECUTION" //单机串行
discardLater = "DISCARD_LATER" //丢弃后续调度
coverEarly = "COVER_EARLY" //覆盖之前调度
)
// RunReq 触发任务请求参数
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 killReq struct {
JobID int64 `json:"jobId"` // 任务ID
}
//忙碌检测请求参数
type idleBeatReq struct {
JobID int64 `json:"jobId"` // 任务ID
}
// LogReq 日志请求
type LogReq struct {
LogDateTim int64 `json:"logDateTim"` // 本次调度日志时间
LogID int64 `json:"logId"` // 本次调度日志ID
FromLineNum int `json:"fromLineNum"` // 日志开始行号,滚动加载日志
}
// LogRes 日志响应
type LogRes struct {
Code int64 `json:"code"` // 200 表示正常、其他失败
Msg string `json:"msg"` // 错误提示消息
Content LogResContent `json:"content"` // 日志响应内容
}
// LogResContent 日志响应内容
type LogResContent struct {
FromLineNum int `json:"fromLineNum"` // 本次请求,日志开始行数
ToLineNum int `json:"toLineNum"` // 本次请求,日志结束行号
LogContent string `json:"logContent"` // 本次请求日志内容
IsEnd bool `json:"isEnd"` // 日志是否全部加载完
}