Interface CronJobRepository

internal/repository/sql_job.go:11–16

CronJobRepository 定义了定时任务仓库接口

// CronJobRepository 定义了定时任务仓库接口
type CronJobRepository interface {
	Preempt(ctx context.Context) (domain.Job, error)
	Release(ctx context.Context, jobId int64) error
	UpdateTime(ctx context.Context, id int64) error
	UpdateNextTime(ctx context.Context, id int64, nextTime time.Time) error
}

// cronJobRepository 实现了 CronJobRepository 接口
type cronJobRepository struct {