NewCronJobRepository 创建并初始化 cronJobRepository 实例
(dao dao.JobDAO)
| 22 | |
| 23 | // NewCronJobRepository 创建并初始化 cronJobRepository 实例 |
| 24 | func NewCronJobRepository(dao dao.JobDAO) CronJobRepository { |
| 25 | return &cronJobRepository{ |
| 26 | dao: dao, |
| 27 | } |
| 28 | } |
| 29 | |
| 30 | // Preempt 从数据库中抢占一个任务 |
| 31 | func (c *cronJobRepository) Preempt(ctx context.Context) (domain.Job, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected