Preempt 从数据库中抢占一个任务
(ctx context.Context)
| 29 | |
| 30 | // Preempt 从数据库中抢占一个任务 |
| 31 | func (c *cronJobRepository) Preempt(ctx context.Context) (domain.Job, error) { |
| 32 | j, err := c.dao.Preempt(ctx) |
| 33 | if err != nil { |
| 34 | return domain.Job{}, err |
| 35 | } |
| 36 | return domain.Job{ |
| 37 | Id: j.Id, |
| 38 | Expression: j.Expression, |
| 39 | Executor: j.Executor, |
| 40 | Name: j.Name, |
| 41 | }, nil |
| 42 | } |
| 43 | |
| 44 | // Release 释放一个任务 |
| 45 | func (c *cronJobRepository) Release(ctx context.Context, jobId int64) error { |