Struct Primary 

pub struct Primary { /* private fields */ }

A primary database with read-write access

Implementations

impl Primary

pub async fn open( last_snapshot: &Snapshot, additional_logs: &[Log], ) -> Result<Self>

Opens a primary database with the given snapshot and additional logs.

pub fn capture_frames(&mut self) -> Frames

Captures a live stream of frames from the primary database.

pub async fn checkpoint( &self, save_log: impl FnOnce(Log) -> BoxFuture<'static, ()> + Send + 'static, ) -> Result<impl Future<Output = Option<FrameNo>>>

Checkpoints the primary database and returns a future that resolves to the last safely written frame number. The save_log function should save the log to a durable storage, is async, and is not allowed to fail. Checkpoints are exclusive, so only one checkpoint can be in progress at a time.

pub async fn with_connection<A>( &self, f: impl FnOnce(&mut Connection) -> Result<A> + Send + 'static, ) -> Result<Ack<A>>

where A: Send + Unpin + 'static,

Opens a read-write connection to the primary database and runs the provided function. The provided connection uses the rusqlite API.

pub fn into_replica(self) -> Result<Replica, (Error, Primary)>

Converts the primary database into a replica. Fail if not all writes have been checkpointed yet.

Trait Implementations

impl Debug for Primary

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.