customizableWorkUnit is a wrapper around a workUnit that allows for customization of the workUnit. Unlike in other packages, this one does not make use of any types from the top level river package (like `river.Job[T]`).
| 32 | // of the workUnit. Unlike in other packages, this one does not make use of any |
| 33 | // types from the top level river package (like `river.Job[T]`). |
| 34 | type customizableWorkUnit struct { |
| 35 | middleware []rivertype.WorkerMiddleware |
| 36 | nextRetry func() time.Time |
| 37 | timeout time.Duration |
| 38 | work func() error |
| 39 | } |
| 40 | |
| 41 | func (w *customizableWorkUnit) HookLookup(lookup *hooklookup.JobHookLookup) hooklookup.HookLookupInterface { |
| 42 | return hooklookup.NewHookLookup(nil) |
nothing calls this directly
no outgoing calls
no test coverage detected