Struct SqliteMailbox 

pub struct SqliteMailbox { /* private fields */ }

SQLite 邮箱实现

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,

将消息加入队列。

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,

从队列中取出一批消息。

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,

确认一条消息已成功处理，将其从队列中永久删除。

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

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

获取当前邮箱的统计信息。