Struct SqliteContextStore 

pub struct SqliteContextStore { /* private fields */ }

SQLite-backed ContextStore implementation.

Uses WAL mode for concurrent read access and a single Mutex<Connection> for thread-safe write access. All data is stored in two STRICT tables: outputs for node outputs and globals for global key-value pairs.

Implementations

impl SqliteContextStore

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

Open or create a ContextStore at the given path.

Creates the database file and tables if they don’t exist. Enables WAL mode and sets a busy timeout for concurrent access.

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

Create an in-memory ContextStore (for testing).

Trait Implementations

impl ContextStore for SqliteContextStore

fn put( &self, flow_run_id: FlowRunId, node_id: NodeId, value: &Value, ) -> Result<(), ContextStoreError>

Write a node’s output. Enforces write-once semantics:

fn get( &self, flow_run_id: FlowRunId, node_id: NodeId, ) -> Result<Option<Value>, ContextStoreError>

Read a node’s output. Returns None if not yet written.

fn list_keys( &self, flow_run_id: FlowRunId, ) -> Result<Vec<NodeId>, ContextStoreError>

List all node IDs that have outputs for a given flow run.

fn put_global(&self, key: &str, value: &Value) -> Result<(), ContextStoreError>

Write a global key-value pair. Globals are not scoped to a flow run. Write-once semantics: second put for the same key returns GlobalAlreadyExists.

fn upsert_global( &self, key: &str, value: &Value, ) -> Result<(), ContextStoreError>

Write or update a global key-value pair. Unlike put_global, this allows overwriting an existing value. Used for mutable global metadata (e.g., coordinator map).

fn get_global(&self, key: &str) -> Result<Option<Value>, ContextStoreError>

Read a global value. Returns None if not yet written.