MCPcopy Create free account
hub / github.com/riverqueue/river / Timeout

Method Timeout

internal/workunit/work_unit.go:26–26  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

24 Middleware() []rivertype.WorkerMiddleware
25 NextRetry() time.Time
26 Timeout() time.Duration
27 UnmarshalJob() error
28 Work(ctx context.Context) error
29}

Callers 2

makeRetryDecisionMethod · 0.65
executeMethod · 0.65

Implementers 2

callbackWorkUnitinternal/maintenance/job_rescuer_test.
customizableWorkUnitinternal/jobexecutor/job_executor_test

Calls

no outgoing calls

Tested by

no test coverage detected