Skip to main content

Module queue

Module queue

Expand description

Background job queue. Use ferro::queue::Job, ferro::queue::dispatch, etc.

Structs§

CreateJobsTable: Migration that creates the jobs table and its indexes.
FailedJobInfo: A failed job with the error message.
JobInfo: Summary of a single job for introspection.
JobPayload: Serialized job payload stored in the queue.
PendingDispatch: A pending job dispatch.
Queue: Global handle to the queue’s database connection.
QueueConfig: Queue system configuration.
QueueStats: Aggregate stats across all queues.
SingleQueueStats: Per-queue pending/delayed counts.
WorkerConfig: Worker configuration.
WorkerLoop: DB-backed queue worker.

Enums§

Error: Errors that can occur in the queue system.
JobState: Job status for introspection queries.

Traits§

Job: A job that can be executed by a queue worker.
Queueable: Trait for types that can be dispatched to a queue.
TenantScopeProvider: Injects tenant scope around job execution.

Functions§

dispatch: Dispatch a job using the global queue.
dispatch_later: Dispatch a job with a delay.
dispatch_to: Dispatch a job to a specific queue.
register_tenant_capture_hook: Register the tenant capture hook.

Type Aliases§

Worker: Type alias for API continuity with callers that use the old Worker name.