Struct FileStore 

pub struct FileStore { /* private fields */ }

File-based message store implementation.

Uses multiple files for storage:

• .body: Append-only file containing raw message data
• .header: Index file mapping sequence numbers to message positions
• .seqnums: Stores sender and target sequence numbers
• .session: Stores session creation time

Implementations

impl FileStore

pub fn new( directory: impl AsRef<Path>, name: &str, ) -> Result<FileStore, StoreError>

Creates a new file store in the specified directory with the given name.

Errors

Returns StoreError::Initialization if the store files cannot be created or read.

Trait Implementations

impl MessageStore for FileStore

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

where 'life0: 'async_trait, 'life1: 'async_trait, FileStore: '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>>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileStore: '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<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileStore: '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<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileStore: '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<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileStore: '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<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileStore: '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.