MCPcopy Index your code
hub / github.com/riverqueue/river / NextRetry

Method NextRetry

work_unit_wrapper.go:37–37  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

35 return w.worker.Middleware(w.jobRow)
36}
37func (w *wrapperWorkUnit[T]) NextRetry() time.Time { return w.worker.NextRetry(w.job) }
38func (w *wrapperWorkUnit[T]) Timeout() time.Duration { return w.worker.Timeout(w.job) }
39func (w *wrapperWorkUnit[T]) Work(ctx context.Context) error { return w.worker.Work(ctx, w.job) }
40

Callers

nothing calls this directly

Calls 1

NextRetryMethod · 0.65

Tested by

no test coverage detected