Struct SyncManager 

pub struct SyncManager<S>
where
    S: CheckpointStore,
{ /* private fields */ }

Manager for handling sync operations with checkpoint tracking.

The SyncManager is generic over the checkpoint store type S, providing storage-agnostic checkpoint management.

Implementations

impl<S> SyncManager<S>

where S: CheckpointStore,

pub fn new(store: S) -> SyncManager<S>

Create a new sync manager with the given store.

By default, checkpoint emission is enabled.

pub fn new_without_emit(store: S) -> SyncManager<S>

Create a new sync manager with checkpoint emission disabled.

pub fn with_emit_checkpoints(self, emit: bool) -> SyncManager<S>

Set whether to emit checkpoints.

pub fn emit_checkpoints(&self) -> bool

Check if checkpoint emission is enabled.

pub fn store(&self) -> &S

Get a reference to the underlying store.

pub async fn emit_checkpoint<C>( &self, checkpoint: &C, phase: SyncPhase, ) -> Result<(), Error>

where C: Checkpoint,

Emit checkpoint for any database-specific checkpoint type.

pub async fn read_checkpoint<C>(&self, phase: SyncPhase) -> Result<C, Error>

where C: Checkpoint,

Read and parse checkpoint into database-specific type.

impl SyncManager<NullStore>

pub fn disabled() -> SyncManager<NullStore>

Create a sync manager that does nothing (for disabled checkpoint storage).