Method Preempt

internal/repository/sql_job.go:12–12 · view source on GitHub ↗

(ctx context.Context)

Source from the content-addressed store, hash-verified

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

PreemptMethod · 0.65

cronJobRepositoryinternal/repository/sql_job.go

jobDAOinternal/repository/dao/sql_job.go

no outgoing calls

no test coverage detected