Method LockJob

database/common/store.go:128–128 · view source on GitHub ↗

(ctx context.Context, jobID int64, entityID string)

Source from the content-addressed store, hash-verified

126	DeleteJob(ctx context.Context, jobID int64) error
127	UnlockJob(ctx context.Context, jobID int64, entityID string) error
128	LockJob(ctx context.Context, jobID int64, entityID string) error
129	BreakLockJobIsQueued(ctx context.Context, jobID int64) error
130
131	DeleteInactionableJobs(ctx context.Context, olderThan time.Duration) error

consumeQueuedJobsMethod · 0.65

TestJobWatcherMethod · 0.65

sqlDatabasedatabase/sql/sql.go

Storedatabase/common/mocks/Store.go

Store_Expecterdatabase/common/mocks/Store.go

no outgoing calls

TestJobWatcherMethod · 0.52