Struct HaematiteStore 

pub struct HaematiteStore { /* private fields */ }

DurableStore implementation that delegates directly to haematite’s EventStore.

The real EventStore is synchronous (every call blocks on the owning shard actor’s reply), so each async method below completes on its first poll. The synchronous bridge in super::bridge relies on exactly that.

Implementations

impl HaematiteStore

pub const fn new(event_store: Arc<EventStore>) -> Self

Wraps a haematite EventStore handle.

Trait Implementations

impl Clone for HaematiteStore

fn clone(&self) -> HaematiteStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HaematiteStore

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

Formats the value using the given formatter.

impl DurableStore for HaematiteStore

fn append<'life0, 'life1, 'async_trait>( &'life0 self, stream_key: &'life1 str, payload: Vec<u8>, expected_seq: u64, ) -> Pin<Box<dyn Future<Output = Result<u64, DurabilityError>> + Send + 'async_trait>>

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

Appends payload to stream_key if expected_seq matches the stream head.

fn read_from<'life0, 'life1, 'async_trait>( &'life0 self, stream_key: &'life1 str, offset: u64, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredEntry>, DurabilityError>> + Send + 'async_trait>>

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

Reads entries from stream_key beginning at offset, up to limit entries.

fn cas<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, old_value: u64, new_value: u64, ) -> Pin<Box<dyn Future<Output = Result<(), DurabilityError>> + Send + 'async_trait>>

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

Atomically replaces a stored numeric value if it equals old_value.

fn read_value<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, DurabilityError>> + Send + 'async_trait>>

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

Reads a numeric value previously updated through compare-and-swap.

fn scan<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredEntry>, DurabilityError>> + Send + 'async_trait>>

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

Scans entries by store prefix.

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

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

Flushes buffered writes so completed durable operations are persisted.