DeadJobManagementHandler returns a http handler with endpoints for dead job management: - /dead-jobs: JSON/HTML response with content negotiation.

New returns an instance of Worker initialized with defaults.

NewJob sanitizes the given JobSpec and returns a new instance of Job created with the given job.

Default run options.

Default run options.

Default run options.

ExponentialBackoff implements exponential backoff.

Job represents the specification for async processing and also maintains the progress so far.

JobHandler is used to execute a job by the Worker when ready.

JobOptions control the retry strategy and the job execution timeout.

JobSpec is the specification for async processing.

JobTypeStats is the statistics for the job type with number of active and dead jobs.

LinearBackoff will backoff linearly.

LinearModBackoff will backoff linearly.

RetryableError can be returned by a JobFunc to instruct the worker to attempt retry.

Worker provides asynchronous job processing using a job processor.

BackoffStrategy defines the different kind of Backoff strategy for retry.

JobProcessor represents a special job store or queue that holds jobs and processes them via Process() only after the jobs are ready.

BackoffFunc is a adapter to use ordinary function as retry BackoffStrategy.

JobExecutorFunc is invoked by JobProcessor for ready jobs.

JobFunc is invoked by the Worker when a job is ready.