Struct SyncManager 

pub struct SyncManager { /* private fields */ }

Manages synchronization across replicas

Implementations

impl SyncManager

pub fn new(replica_set: Arc<ReplicaSet>, log: Arc<ReplicationLog>) -> Self

Create a new sync manager

pub fn set_sync_mode(&self, mode: SyncMode)

Set the synchronization mode

pub fn sync_mode(&self) -> SyncMode

Get the current synchronization mode

pub fn set_sync_timeout(&mut self, timeout: Duration)

Set the sync timeout

pub async fn replicate(&self, data: Vec<u8>) -> Result<LogEntry>

Replicate data to all replicas according to sync mode

pub async fn catchup( &self, replica_id: &str, from_sequence: u64, ) -> Result<Vec<LogEntry>>

Catch up a lagging replica

pub fn current_position(&self) -> u64

Get the current log position

pub fn verify_entry(&self, sequence: u64) -> Result<bool>

Verify log entry integrity