Struct QoxideQueue 

pub struct QoxideQueue { /* private fields */ }

A SQLite-backed message queue.

Messages flow through states: Pending → Reserved → Completed. Use add to enqueue, reserve to dequeue, and complete or fail to finish processing.

Implementations

impl QoxideQueue

pub fn new() -> Self

Creates a new in-memory queue.

Data is lost when the queue is dropped. For persistence, use new_with_path.

pub fn new_with_path(path: &str) -> Self

Creates a new file-backed queue at the given path.

Enables WAL mode for better concurrent read performance. The database file is created if it doesn’t exist.

pub fn size(&self) -> Result<QueueSize, Error>

Returns the count of messages in each state.

pub fn add(&mut self, payload: Vec<u8>) -> Result<i64, Error>

Adds a message to the queue with the given payload.

Returns the message ID which can be used with complete or fail.

pub fn reserve(&mut self) -> Result<(i64, Vec<u8>), Error>

Atomically reserves the next pending message.

Returns the message ID and payload. The message state changes from Pending to Reserved. Returns an error if no pending messages are available.

pub fn complete(&self, id: i64) -> Result<(), Error>

Marks a reserved message as successfully completed.

pub fn fail(&mut self, id: i64) -> Result<(), Error>

Marks a reserved message as failed, returning it to pending state.

The message will be available for reserve again.

Trait Implementations

impl Default for QoxideQueue

fn default() -> Self

Returns the “default value” for a type.