Expand description
Background job abstractions.
These primitives are intentionally local and in-memory. JobQueue and
AsyncJobQueue run jobs stored in the current process; they do not persist,
schedule, retry, distribute, or reserve jobs across workers.
Structs§
- Async
JobQueue - In-memory asynchronous job queue.
- Durable
JobRecord - Persisted durable job data returned by a store.
- Durable
JobRegistry - Immutable handler registry shared by workers.
- Durable
JobWorker - Bounded, multi-worker-safe durable job executor.
- JobError
- Error emitted by a background job.
- JobExecution
Context - Context supplied to a durable job handler.
- JobExecution
Error - Safe handler failure used to choose retry or dead-letter behavior.
- JobFailure
- Failed job details from a queue run.
- JobObserver
Channel - Observer implementation that sends observed job events to a channel.
- JobQueue
- In-memory job queue.
- JobReport
- Report from a queue run.
- JobRetry
Policy - Exponential full-jitter retry policy.
- Lease
Request - Parameters for an atomic lease operation.
- NewJob
- A validated job ready to enqueue.
- Observed
JobContext - Context carried through observed job execution.
- Observed
JobRunner - Runner that observes synchronous and asynchronous jobs without owning a queue.
- Store
Stats - Aggregate durable store counts.
- Worker
Config - Bounded worker configuration.
- Worker
Report - Aggregate results from a worker run.
Enums§
- Durable
JobError - Error returned by durable job infrastructure.
- Enqueue
Result - Result of an idempotent enqueue operation.
- JobDisposition
- Store action after an unsuccessful execution.
- JobResult
Status - Completion status for an observed job run.
- JobStatus
- Persisted durable job state.
- Observed
JobEvent - Structured event emitted by a channel-backed job observer.
Traits§
- Async
Job - Asynchronous job abstraction for Tokio-backed background work.
- Durable
JobHandler - Named durable job handler.
- Durable
JobStore - Persistence contract for at-least-once durable jobs.
- Job
- Synchronous job abstraction for lightweight background work.
- JobObserver
- Observer hook for job execution.
Functions§
- job_
observer_ channel - Creates a channel-backed job observer and its receiver.
Type Aliases§
- Durable
Result - Result type used by durable job stores and workers.
- Result
- Result type for background job execution.