Struct SqliteMetadataStore 

pub struct SqliteMetadataStore { /* private fields */ }

SQLite-backed persistent metadata store.

Opens its own rusqlite::Connection to the supplied database path — the same path the mob’s MobStorage uses, but with a separate handle. Cross-handle access is safe; meerkat #445’s notify-based event-store watcher already runs in this configuration. The mobkit_metadata table is created on init and is independent of meerkat-mob’s own schema, so opening order doesn’t matter.

Schema:

CREATE TABLE mobkit_metadata (
    mob_id  TEXT NOT NULL,
    key     TEXT NOT NULL,
    value   TEXT NOT NULL,
    PRIMARY KEY (mob_id, key)
)

The subscription cursor lives at key = "subscription_cursor", stored as a base-10 string for simple human inspection. Future metadata fields land here under their own keys.

Implementations

impl SqliteMetadataStore

pub fn open(path: impl AsRef<Path>) -> Result<Self, MetadataStoreError>

Open (or create) a SQLite metadata store at path.

path should typically be the same database the mob’s MobStorage uses; the table is mobkit_metadata and won’t collide with meerkat-mob’s own tables.

pub fn in_memory() -> Result<Self, MetadataStoreError>

Open an in-memory SQLite store (for tests).

Trait Implementations

impl PersistentMetadataStore for SqliteMetadataStore

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.