Struct SledOutboxStore 

pub struct SledOutboxStore {
    tree: Tree,
    encryption: Option<StorageEncryption>,
}

An OutboxStore implementation using sled for storage.

Fields

tree: Tree

encryption: Option<StorageEncryption>

Implementations

impl SledOutboxStore

pub fn new(db: Db, encryption: Option<StorageEncryption>) -> Result<Self>

Creates a new SledOutboxStore.

Arguments

• db - The sled::Db instance to use for storage.
• encryption - The optional StorageEncryption to use for encrypting messages.

Errors

This function will return an error if the outbox tree cannot be opened.

fn serialize_message(&self, msg: &Message) -> Result<Vec<u8>>

Serializes a Message and encrypts it if encryption is enabled.

fn deserialize_message(&self, data: &[u8]) -> Result<Message>

Decrypts and deserializes a Message.

Trait Implementations

impl OutboxStore for SledOutboxStore

fn add_pending<'life0, 'async_trait>( &'life0 self, msg: Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Adds a new message to the outbox.

fn get_pending<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

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

Retrieves all pending messages from the outbox.

fn remove_pending<'life0, 'life1, 'async_trait>( &'life0 self, msg_id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Removes a pending message from the outbox.

fn count_pending<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

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

Returns the number of pending messages in the outbox.