Struct SqliteMailbox 

pub struct SqliteMailbox { /* private fields */ }

SQLite mailbox implementation

Implementations

impl SqliteMailbox

pub async fn new<P: AsRef<Path>>(database_path: P) -> StorageResult<Self>

pub async fn with_config(config: SqliteConfig) -> StorageResult<Self>

Trait Implementations

impl Mailbox for SqliteMailbox

fn enqueue<'life0, 'async_trait>( &'life0 self, from: Vec<u8>, payload: Vec<u8>, priority: MessagePriority, ) -> Pin<Box<dyn Future<Output = StorageResult<Uuid>> + Send + 'async_trait>>

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

Enqueue a message.

fn dequeue<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<MessageRecord>>> + Send + 'async_trait>>

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

Dequeue a batch of messages from the queue.

fn ack<'life0, 'async_trait>( &'life0 self, message_id: Uuid, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

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

Acknowledge that a message has been successfully processed, permanently removing it from the queue.

fn status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<MailboxStats>> + Send + 'async_trait>>

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

Get current mailbox statistics.

fn set_depth_observer(&self, observer: Arc<dyn MailboxDepthObserver>) -> bool

Install a MailboxDepthObserver that receives a post-enqueue queued-message count on every enqueue.