Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

Immutable rows keyed by (doc_id, sid, time_start). Rows stay pending until their actor prefix is contiguous and their dependencies are stored.

Implementations

impl SqliteStore

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

Opens or creates a durable database file (WAL, synchronous FULL).

pub fn open_in_memory() -> Result<Self>

pub fn new(db: Connection) -> Result<Self>

Installs the schema on an existing connection.

pub fn connection(&self) -> &Connection

pub fn append(&mut self, rows: &[PatchRow]) -> Result<AppendResult>

Validates and stores rows of one document in one IMMEDIATE transaction. Exact retransmissions are ignored; a conflict rolls back the whole batch.

pub fn vector(&self, doc_id: &str) -> Result<VersionVector>

pub fn missing( &self, doc_id: &str, remote: &VersionVector, ) -> Result<Vec<PatchRow>>

Ready rows the peer lacks, ordered by actor and clock.

pub fn sync_state( &mut self, doc_id: &str, remote: &VersionVector, ) -> Result<(Vec<PatchRow>, VersionVector)>

missing and vector from one consistent snapshot.