Versions in this module Expand all Collapse all v1 v1.0.0 Jun 11, 2019 Changes in this version + const API_JOB_CREATE + const API_JOB_DELETE + const API_JOB_FETCH + const API_JOB_KILL + const API_JOB_LIST + const API_JOB_LOG + const API_WORK_LIST + const JOB_EVENT_DELETE + const JOB_EVENT_KILL + const JOB_EVENT_SAVE + const JOB_KILLER_DIR + const JOB_LOCK_DIR + const JOB_SAVE_DIR + const JOB_WORKER_DIR + var ERROR_LOCK_ALREADY_REQUIRED = errors.New("The Lock has been occupied！") + var ERROR_NO_LOCAL_IP_FOUND = errors.New("Nic IP not found! ") + var Manage *utils.Container + func BuildResponse(errno int, msg string, data interface{}) (resp []byte, err error) + func ExtractJobName(jobKey string) string + func ExtractKillerName(killerKey string) string + func ExtractWorkerIP(regKey string) string + func InitContainer() (err error) + type Job struct + Command string + CronExpr string + Name string + func UnpackJob(value []byte) (ret *Job, err error) + type JobEvent struct + EventType int + Job *Job + func BuildJobEvent(eventType int, job *Job) (jobEvent *JobEvent) + type JobExecuteInfo struct + CancelCtx context.Context + CancelFunc context.CancelFunc + Job *Job + PlanTime time.Time + RealTime time.Time + func BuildJobExecuteInfo(jobSchedulePlan *JobSchedulePlan) (jobExecuteInfo *JobExecuteInfo) + type JobExecuteResult struct + EndTime time.Time + Err error + ExecuteInfo *JobExecuteInfo + Output []byte + StartTime time.Time + type JobLog struct + Command string + EndTime int64 + Err string + JobName string + Output string + PlanTime int64 + ScheduleTime int64 + StartTime int64 + type JobLogFilter struct + JobName string + type JobSchedulePlan struct + Expr *cronexpr.Expression + Job *Job + NextTime time.Time + func BuildJobSchedulePlan(job *Job) (jobSchedulePlan *JobSchedulePlan, err error) + type LogBatch struct + Logs []interface{} + type Response struct + Data interface{} + Errno int + Msg string + type SortLogByStartTime struct + SortOrder int
Go to main page