Crate qoxide

Crate qoxide 

Source
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§

QoxideQueue
A SQLite-backed message queue.
QueueSize
A breakdown of message counts by state.

Enums§

MessageState
The state of a message in the queue.