job

type Cmd struct {
	*Job
	*Timer
	// contains filtered or unexported fields
}

type Config struct {
	Enable bool

	EtcdConfigKey   string // jupiter.etcdv3.xxxxxx
	ReqTimeout      int    // 请求操作ETCD的超时时间，单位秒
	RequireLockTime int64  // 抢锁等待时间，单位秒

	HostName string
	AppIP    string
	// contains filtered or unexported fields
}

type Cron struct {
	*Worker
	*cron.Cron
	// contains filtered or unexported fields
}

type CronJob = cron.Job

type CronTaskStatus string

type EntryID = cron.EntryID

type FuncJob func() error

type Job struct {
	ID      string   `json:"id"`
	Name    string   `json:"name"`
	Script  string   `json:"script"`
	Timers  []*Timer `json:"timers"`
	Enable  bool     `json:"enable"`  // 可手工控制的状态
	Timeout int64    `json:"timeout"` // 单位时间秒，任务执行时间超时设置，大于 0 时有效
	Env     string   `json:"env"`
	Zone    string   `json:"zone"`
	Nodes   []string `json:"nodes"`

	// 执行任务失败重试次数
	// 默认为 0，不重试
	RetryCount int `json:"retry_count"`

	// 执行任务失败重试时间间隔
	// 单位秒，如果不大于 0 则马上重试
	RetryInterval int `json:"retry_interval"`

	// 任务类型
	// 0: 普通任务，各节点均可运行
	// 1: 单机任务，同时只能单节点在线
	JobType int `json:"job_type"`

	// 用于访问etcd
	*Worker `json:"-"`
	// contains filtered or unexported fields
}

type JobWrapper = cron.JobWrapper

type Jobs map[string]*Job

type NamedJob interface {
	Run() error
}

type OnceJob struct {
	Job

	TaskID uint64 `json:"task_id"`
}

type Process struct {

	// parse from key path
	ID     string `json:"id"` // pid
	JobID  string `json:"jobId"`
	NodeID string `json:"nodeId"`
	TaskID uint64 `json:"task_id"`
	// parse from value
	ProcessVal
	// contains filtered or unexported fields
}

type ProcessVal struct {
	Time   time.Time `json:"time"`   // 开始执行时间
	Killed bool      `json:"killed"` // 是否强制杀死
}

type Schedule = cron.Schedule

type Task struct {
	TaskID uint64
	// contains filtered or unexported fields
}

type TaskOption func(t *Task)

type TaskResult struct {
	TaskID     uint64         `json:"task_id"`
	Status     CronTaskStatus `json:"status"`
	Job        *Job           `json:"job"`
	Logs       string         `json:"logs"`
	RunOn      string         `json:"run_on"`
	ExecutedAt time.Time      `json:"executed_at"`
	FinishedAt *time.Time     `json:"finished_at"`
}

type Timer struct {
	ID   string `json:"id"`
	Cron string `json:"timer"`

	Schedule Schedule `json:"-"`
}

type Worker struct {
	*Config
	*etcdv3.Client
	*Cron

	ID             string
	ImmediatelyRun bool // 是否立即执行
	// contains filtered or unexported fields
}