Skip to main content

Module queue

Module queue 

Source
Expand description

Queue subsystem. Jobs dispatched as serialized payloads; workers deserialize and run.

Structs§

DatabaseDriver
JobRegistration
JobRegistry
QueueHandle
QueuePayload

Traits§

QueueDriver

Functions§

collect_inventory_registry
dispatch_payload
Push a job onto the configured queue (helper for the Job::dispatch().await? form).
run_worker
Run the queue worker loop: pop a job, look up its runner, run it, retry on failure.

Type Aliases§

JobRunner