Struct MirrorStore 

pub struct MirrorStore { /* private fields */ }

Persistent local mirror of remote API data.

Implementations

impl MirrorStore

pub async fn in_memory() -> Result<Self>

Open an in-memory mirror — useful for tests and short-lived agents.

pub async fn open(path: &str) -> Result<Self>

Open or create an on-disk mirror at path.

pub fn pool(&self) -> &SqlitePool

Direct access to the underlying pool — handy for ad-hoc admin tasks. Most callers want Self::query instead, which is read-only.

pub async fn migrate_to(&self, target_version: Option<i64>) -> Result<()>

Migrate the schema to the latest version (or a specific target).

pub async fn register_resource(&self, name: &str) -> Result<()>

Register a resource name so it appears in Self::list_resources. Idempotent — calling twice is a no-op.

pub async fn list_resources(&self) -> Result<Vec<String>>

List every resource that has been registered or seen via apply_delta.

pub async fn apply_delta( &self, delta: &Delta, strategy: &dyn ConflictStrategy, ) -> Result<AppliedDelta>

Apply a delta through strategy. The delta is always recorded in the event log; whether it lands in mirror_records depends on the strategy’s ConflictResolution decision.

pub async fn get_record( &self, resource: &str, record_id: &str, ) -> Result<Option<MirroredRecord>>

Fetch a single record by (resource, record_id).

pub async fn list_records(&self, resource: &str) -> Result<Vec<MirroredRecord>>

List every record for a resource.

pub async fn record_counts(&self) -> Result<Vec<(String, i64)>>

Count records per resource — useful for dashboards / smoke tests.

pub async fn event_count(&self, resource: &str) -> Result<i64>

Event count per resource.

pub async fn get_cursor( &self, source: &str, resource: &str, ) -> Result<Option<String>>

Get the cursor for (source, resource), if one has been persisted.

pub async fn set_cursor( &self, source: &str, resource: &str, cursor: Option<&str>, ) -> Result<()>

Persist a cursor for (source, resource).

pub async fn query(&self, sql: &str) -> Result<Vec<Map<String, Value>>>

Run a read-only SQL query and return the rows as JSON objects.

The query must start with SELECT, WITH, or PRAGMA (case- insensitive). Multi-statement input is rejected. Use Self::pool directly for admin tasks.

pub fn subscribe(&self) -> impl Stream<Item = Delta> + Send

Subscribe to a live stream of deltas as they are applied.

Trait Implementations

impl Clone for MirrorStore

fn clone(&self) -> MirrorStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.