Struct InMemoryMetadataStore 

pub struct InMemoryMetadataStore { /* private fields */ }

In-memory persistent metadata store.

“Persistent” is aspirational here — the values survive Arc<...> clones but reset to empty on process restart. Used when no SQLite mob storage is configured. The structural-events subscription falls back to “start at latest” on restart in this case, which is the right behaviour: in-memory deployments don’t have a persistent ledger to replay against either.

Implementations

impl InMemoryMetadataStore

pub fn new() -> Self

Trait Implementations

impl Debug for InMemoryMetadataStore

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

Formats the value using the given formatter.

impl Default for InMemoryMetadataStore

fn default() -> InMemoryMetadataStore

Returns the “default value” for a type.

impl PersistentMetadataStore for InMemoryMetadataStore

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

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

Read the last-projected mob events cursor for mob_id. Returns Ok(None) when no cursor has been written yet (fresh deploy or in-memory deployment that just started).

fn set_subscription_cursor<'life0, 'life1, 'async_trait>( &'life0 self, mob_id: &'life1 str, cursor: u64, ) -> Pin<Box<dyn Future<Output = Result<(), MetadataStoreError>> + Send + 'async_trait>>

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

Persist the last-projected mob events cursor for mob_id.