job

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

type Executor interface {
	// Executor 叫什么
	Name() string
	// Exec ctx 是整个任务调度的上下文
	// 当从 ctx.Done 有信号的时候，就需要考虑结束执行
	// 具体实现来控制
	// 真正去执行一个任务
	Exec(ctx context.Context, j domain.Job) error
}

type Job interface {
	Name() string
	Run() error
}

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

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

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

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