Skip to main content

Module queue

Module queue 

Source
Expand description

Job queue — disk-backed, multi-process safe (atomic file claim).

Structs§

EnqueueResponse
QueueMessage

Functions§

configure_disk
Configure file-backed queue storage root.
enqueue
Enqueue a worker job (persisted to disk; any Resuma process may claim it).
queue_stats
Queue depth stats (pending, processing, …).
register_queue
Register a named queue and spawn its disk consumer loop.
start_consumers
Start disk pollers for all queues (multi-process workers).