Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

In-memory message store.

Stores messages in a BTreeMap for efficient range queries. Not persistent - all data is lost when the process exits.

Implementations

impl MemoryStore

pub fn new() -> MemoryStore

Creates a new empty memory store.

pub fn with_initial_seqs(sender_seq: u64, target_seq: u64) -> MemoryStore

Creates a new memory store with initial sequence numbers.

Arguments

• sender_seq - Initial sender sequence number
• target_seq - Initial target sequence number

pub fn message_count(&self) -> usize

Returns the number of stored messages.

pub fn contains(&self, seq_num: u64) -> bool

Checks if a message with the given sequence number exists.

Trait Implementations

impl Debug for MemoryStore

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

Formats the value using the given formatter.

impl Default for MemoryStore

fn default() -> MemoryStore

Returns the “default value” for a type.

impl MessageStore for MemoryStore

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

where 'life0: 'async_trait, 'life1: 'async_trait, MemoryStore: 'async_trait,

Stores an outgoing message for potential resend.

fn get_range<'life0, 'async_trait>( &'life0 self, begin: u64, end: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<OwnedMessage>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemoryStore: 'async_trait,

Retrieves messages for a resend request.

fn next_sender_seq(&self) -> u64

Returns the next sender sequence number.

fn next_target_seq(&self) -> u64

Returns the next expected target sequence number.

fn set_next_sender_seq(&self, seq: u64)

Sets the next sender sequence number.

fn set_next_target_seq(&self, seq: u64)

Sets the next expected target sequence number.

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

where 'life0: 'async_trait, MemoryStore: 'async_trait,

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

fn creation_time(&self) -> SystemTime

Returns the creation time of the store/session.

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

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

Refreshes the store from persistent storage.