Struct SyncCoordinator 

pub struct SyncCoordinator { /* private fields */ }

Sync coordinator for managing multi-device state

Implementations

impl SyncCoordinator

pub fn new(device_id: DeviceId) -> Self

Creates a new sync coordinator

Arguments

• device_id - This device’s identifier

pub fn device_id(&self) -> &DeviceId

Gets this device’s ID

pub fn register_device(&self, device_id: DeviceId) -> SyncResult<()>

Registers a new device

Arguments

• device_id - The device to register

pub fn unregister_device(&self, device_id: &DeviceId) -> SyncResult<()>

Unregisters a device

Arguments

• device_id - The device to unregister

pub fn update_device_status( &self, device_id: &DeviceId, status: DeviceStatus, ) -> SyncResult<()>

Updates device status

Arguments

• device_id - The device to update
• status - The new status

pub fn get_device(&self, device_id: &DeviceId) -> Option<DeviceMetadata>

Gets device metadata

Arguments

• device_id - The device to query

pub fn list_devices(&self) -> Vec<DeviceMetadata>

Lists all registered devices

pub fn list_online_devices(&self) -> Vec<DeviceMetadata>

Lists all online devices

pub fn cleanup_stale_devices(&self, timeout_secs: u64) -> usize

Checks for stale devices and marks them offline

Arguments

• timeout_secs - Timeout in seconds

pub fn start_sync_session( &self, target_device: DeviceId, ) -> SyncResult<SyncSession>

Starts a sync session between two devices

Arguments

• target_device - The device to sync with

pub fn complete_sync_session(&self, session_id: &str) -> SyncResult<()>

Completes a sync session

Arguments

• session_id - The session to complete

pub fn active_sessions(&self) -> Vec<SyncSession>

Gets active sync sessions

pub fn completed_sessions(&self) -> Vec<SyncSession>

Gets completed sync sessions

pub fn sync_crdt<T: Crdt>( &self, local_crdt: &mut T, remote_crdt: &T, ) -> SyncResult<()>

Synchronizes CRDT state with another device

Arguments

• local_crdt - Local CRDT state
• remote_crdt - Remote CRDT state

pub fn create_delta(&self, base: &[u8], target: &[u8]) -> SyncResult<Delta>

Creates a delta between two data versions

Arguments

• base - Base data
• target - Target data

pub fn apply_delta(&self, base: &[u8], delta: &Delta) -> SyncResult<Vec<u8>>

Applies a delta to base data

Arguments

• base - Base data
• delta - Delta to apply

pub fn update_device_clock( &self, device_id: &DeviceId, clock: VectorClock, ) -> SyncResult<()>

Updates device clock

Arguments

• device_id - Device to update
• clock - New clock value

pub fn compare_device_clocks( &self, device1: &DeviceId, device2: &DeviceId, ) -> SyncResult<ClockOrdering>

Compares clocks between two devices

Arguments

• device1 - First device
• device2 - Second device