Struct Syncer 

pub struct Syncer { /* private fields */ }

Holds the registered SyncSources and runs them against a MirrorStore.

Implementations

impl Syncer

pub fn new(store: MirrorStore) -> Self

Build a syncer with the LastWriteWins default strategy.

pub fn with_strategy( store: MirrorStore, strategy: Arc<dyn ConflictStrategy>, ) -> Self

Build a syncer with a custom conflict strategy.

pub fn register_source(&mut self, source: Arc<dyn SyncSource>)

Register a source so it can be referenced by id later.

pub fn store(&self) -> &MirrorStore

Read-only access to the store, e.g. for queries.

pub fn source(&self, id: &str) -> Option<Arc<dyn SyncSource>>

Look up a source by id.

pub async fn sync_source(&self, source_id: &str) -> Result<SyncReport>

Sync every batch a source is able to produce in one go. Stops when the source reports has_more = false or returns an empty batch.

pub async fn sync_stream( &self, source: &dyn SyncSource, cursor: Option<String>, ) -> Result<u64>

Drain a source’s SyncSource::subscribe stream into the store.

Each delta is applied immediately as it arrives. Returns the count of deltas successfully applied. Stops when the stream ends or errors.

pub async fn sync_with(&self, source: &dyn SyncSource) -> Result<SyncReport>

Sync a single concrete SyncSource (handy when callers manage their own registry).