Struct LocalQueue 

pub struct LocalQueue { /* private fields */ }

Local disk-persisted queue on turso (localqueue.v1).

Implements the Queue trait (send/receive/ack/nack/purge). Messages survive process restarts, and multiple LocalQueue handles — including handles in different OS processes — can safely share one data directory.

Implementations

impl LocalQueue

pub async fn new(data_dir: PathBuf) -> Result<Self>

Create a new local queue store rooted at the given data directory.

The directory is created if missing; the store lives at <data_dir>/localqueue.sqlite.

pub async fn from_binding(binding: LocalQueueBinding) -> Result<Self>

Create a LocalQueue from a LocalQueueBinding.

pub fn data_dir(&self) -> &PathBuf

Get the data directory path (the directory that holds localqueue.sqlite).

Trait Implementations

impl Binding for LocalQueue

impl Debug for LocalQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Queue for LocalQueue

fn nack<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _queue: &'life1 str, receipt_handle: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Negative-acknowledge a message: make it immediately visible again.

Same receipt rules as ack: a stale receipt (the message was redelivered and a newer receipt supersedes this one) is rejected; a receipt for an already-deleted message is an idempotent no-op.

fn purge<'life0, 'life1, 'async_trait>( &'life0 self, _queue: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete every message in the queue, visible or in flight.

fn send<'life0, 'life1, 'async_trait>( &'life0 self, _queue: &'life1 str, message: MessagePayload, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a message to the specified queue

fn receive<'life0, 'life1, 'async_trait>( &'life0 self, _queue: &'life1 str, max_messages: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<QueueMessage>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Receive up to max_messages (1..=10) from the specified queue

fn ack<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _queue: &'life1 str, receipt_handle: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Acknowledge a message using its receipt handle (idempotent)