Struct Frames 

pub struct Frames { /* private fields */ }

Live stream of frames from the primary database. Useful if you need a higher granularity than the checkpointing mechanism.

Implementations

impl Frames

pub async fn next(&mut self) -> Result<Option<Vec<Frame>>>

Waits and returns the next batch of frames, or None if the database is closed.

pub async fn try_next(&mut self) -> Result<Vec<Frame>>

Returns the next batch of frames if available, or an Error if there is no new frames availabe.

pub fn ack_replicated(&self, last_replicated_frame_no: FrameNo)

Acknowledges that the frames up to the given frame number have been replicated. This will resolve any pending acks waiting for these frames to be safely replicated.