task

type ContextTaskExec interface {
	ExecContext(context.Context, map[string]string) ([]string, error)
}

type Observer interface {
	Observe(Result)
}

type ObserverFunc func(Result)

type Registry struct {
	// contains filtered or unexported fields
}

type Result struct {
	// Name 是任务名称。
	Name string
	// StartedAt 是任务开始时间。
	StartedAt time.Time
	// Duration 是任务执行耗时。
	Duration time.Duration
	// Output 是任务输出。
	Output []string
	// Err 是任务执行错误。
	Err error
}

type Scheduler struct {
	// contains filtered or unexported fields
}

type Task struct {
	// Name 是任务的稳定唯一名称。
	Name string
	// Expression 是可选的 Cron 表达式，空值表示仅注册、不自动调度。
	Expression string
	// Args 是自动调度时传递给执行器的参数。
	Args map[string]string
	// Exec 是任务执行器。
	Exec TaskExec
}

type TaskExec interface {
	Exec(arg map[string]string) ([]string, error)
}