Struct SyncSession 

pub struct SyncSession { /* private fields */ }

Orchestrates a sync session between two databases.

The initiator drives the protocol: sends Hello, computes diffs, builds patches, and coordinates push/pull phases. The responder answers requests and applies patches.

Implementations

impl SyncSession

pub fn new(config: SyncConfig) -> Self

pub fn sync_as_initiator( &self, manager: &TxnManager, transport: &dyn SyncTransport, ) -> Result<SyncOutcome, SyncError>

Run as the initiator (client) side of a sync session.

pub fn sync_as_responder( &self, manager: &TxnManager, transport: &dyn SyncTransport, ) -> Result<SyncOutcome, SyncError>

Run as the responder (server) side of a sync session.

pub fn sync_tables_as_initiator( &self, manager: &TxnManager, transport: &dyn SyncTransport, ) -> Result<Vec<(Vec<u8>, ApplyResult)>, SyncError>

Run multi-table sync as the initiator.

pub fn handle_table_sync_as_responder( &self, manager: &TxnManager, transport: &dyn SyncTransport, ) -> Result<Vec<(Vec<u8>, ApplyResult)>, SyncError>

Handle multi-table sync as the responder.