Struct Checkpointer 

pub struct Checkpointer { /* private fields */ }

Manages checkpoints for a replication session.

Implementations

impl Checkpointer

pub fn new(source_id: &str, target_id: &str) -> Self

Create a new checkpointer for a replication between source and target.

pub fn replication_id(&self) -> &str

pub async fn read_checkpoint( &self, source: &dyn Adapter, target: &dyn Adapter, ) -> Result<Seq>

Read the checkpoint from both source and target, and find the last common sequence number.

pub async fn write_checkpoint( &self, source: &dyn Adapter, target: &dyn Adapter, last_seq: Seq, ) -> Result<()>

Write the checkpoint to both source and target.