Struct Store 

pub struct Store { /* private fields */ }

Handle to the storage engine.

Cheap to clone (sender + Arc internally). The proxy holds one, and CLI query commands can open their own read-only connections separately.

Implementations

impl Store

pub fn open(config: StoreConfig) -> Result<Self, StoreError>

Open or create the database, run migrations, and spawn the writer thread.

This is called once on proxy startup. It:

1. Creates the parent directory if needed.
2. Opens a read-write connection and runs schema migrations.
3. Spawns the background writer on a dedicated OS thread.
4. Returns a Store handle for recording events.

Errors

Returns an error if:

• The parent directory can’t be created (permissions).
• SQLite can’t open the file (disk full, corrupt file).
• Schema migrations fail (shouldn’t happen on fresh DBs).

pub fn record(&self, event: StoreEvent)

Record an event — non-blocking, fire-and-forget.

If the channel is full (back-pressure), the event is silently dropped. This is intentional: a busy proxy must never block on storage writes. Dropped events are a signal that the writer can’t keep up — in practice this should never happen at normal MCP request rates.

pub fn db_path(&self) -> &PathBuf

Get the database path for opening read-only query connections.

pub fn shutdown(&mut self)

Graceful shutdown — close the channel and wait for the writer to flush.

Call this on proxy shutdown (after stopping new requests, before exiting). Blocks the current thread until all pending events are written to SQLite.

After this returns, the database file is consistent and safe to read.

Trait Implementations

impl Drop for Store

fn drop(&mut self)

Executes the destructor for this type.