jobexecutor

Dec 22, 2025

Changes in this version

type JobExecutor

+ ProducerCallbacks struct{ ... }

+ StuckThresholdOverride time.Duration

May 3, 2025

Changes in this version

type JobExecutor

+ WorkerMiddleware []rivertype.WorkerMiddleware

Mar 17, 2025

Changes in this version

type JobExecutor

+ HookLookupByJob *hooklookup.JobHookLookup

+ HookLookupGlobal hooklookup.HookLookupInterface

+ MiddlewareLookupGlobal middlewarelookup.MiddlewareLookupInterface

Feb 20, 2025

Changes in this version

+ const ContextKeyMetadataUpdates

+ func MetadataUpdatesFromWorkContext(ctx context.Context) (map[string]any, bool)

+ type ClientRetryPolicy interface

+ NextRetry func(job *rivertype.JobRow) time.Time

+ type ErrorHandler interface

+ HandleError func(ctx context.Context, job *rivertype.JobRow, err error) *ErrorHandlerResult

+ HandlePanic func(ctx context.Context, job *rivertype.JobRow, panicVal any, trace string) *ErrorHandlerResult

+ type ErrorHandlerResult struct

+ SetCancelled bool

+ type JobExecutor struct

+ CancelFunc context.CancelCauseFunc

+ ClientJobTimeout time.Duration

+ ClientRetryPolicy ClientRetryPolicy

+ Completer jobcompleter.JobCompleter

+ DefaultClientRetryPolicy ClientRetryPolicy

+ ErrorHandler ErrorHandler

+ GlobalMiddleware []rivertype.WorkerMiddleware

+ InformProducerDoneFunc func(jobRow *rivertype.JobRow)

+ JobRow *rivertype.JobRow

+ SchedulerInterval time.Duration

+ WorkUnit workunit.WorkUnit

+ func (e *JobExecutor) Cancel()

+ func (e *JobExecutor) Execute(ctx context.Context)