Struct InMemoryMessageStore 

pub struct InMemoryMessageStore { /* private fields */ }

An in-memory message store implementation.

This store keeps all messages in memory and does not persist them. Use this only for testing or when persistence is not required.

Trait Implementations

impl Debug for InMemoryMessageStore

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

Formats the value using the given formatter.

impl Default for InMemoryMessageStore

fn default() -> Self

Returns the “default value” for a type.

impl MessageStore for InMemoryMessageStore

fn add<'life0, 'life1, 'async_trait>( &'life0 mut self, sequence_number: u64, message: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Adds a message to the store with the given sequence number.

fn get_slice<'life0, 'async_trait>( &'life0 self, begin: usize, end: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<u8>>>> + Send + 'async_trait>>

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

Retrieves messages in the given sequence number range (inclusive).

fn next_sender_seq_number(&self) -> u64

Returns the next sender sequence number (current + 1).

fn next_target_seq_number(&self) -> u64

Returns the next target sequence number (current + 1).

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

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

Increments the sender sequence number by 1.

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

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

Increments the target sequence number by 1.

fn set_target_seq_number<'life0, 'async_trait>( &'life0 mut self, seq_number: u64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Sets the target sequence number to a specific value.

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

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

Resets the store, clearing all messages and resetting sequence numbers.

fn creation_time(&self) -> DateTime<Utc>

Returns the creation time of the current session.