Expand description
A lightweight local job queue backed by SQLite.
§Example
use qoxide::QoxideQueue;
let mut queue = QoxideQueue::new();
// Add a message
let id = queue.add(b"job payload".to_vec()).unwrap();
// Reserve and process
let (id, payload) = queue.reserve().unwrap();
// ... process the job ...
queue.complete(id).unwrap();Structs§
- Qoxide
Queue - A SQLite-backed message queue.
- Queue
Size - A breakdown of message counts by state.
Enums§
- Message
State - The state of a message in the queue.