Struct GattSyncProtocol 

pub struct GattSyncProtocol { /* private fields */ }

GATT Sync Protocol coordinator

Ties together batching, delta encoding, and chunked transfer for efficient CRDT sync over BLE.

Implementations

impl GattSyncProtocol

pub fn new(node_id: NodeId, config: SyncConfig) -> Self

Create a new sync protocol instance

pub fn with_defaults(node_id: NodeId) -> Self

Create with default config

pub fn set_time(&mut self, time_ms: u64)

Set the current time

pub fn set_mtu(&mut self, mtu: usize)

Set the MTU (after negotiation)

pub fn state(&self) -> SyncState

Get current state

pub fn vector_clock(&self) -> &VectorClock

Get the vector clock

pub fn add_peer(&mut self, peer_id: &NodeId)

Add a peer for sync

pub fn remove_peer(&mut self, peer_id: &NodeId)

Remove a peer

pub fn queue_operation(&mut self, op: CrdtOperation) -> bool

Queue a CRDT operation for sync

pub fn should_sync(&self) -> bool

Check if we should sync now

pub fn prepare_sync(&mut self, peer_id: &NodeId) -> Vec<SyncChunk>

Prepare a sync to a peer

Returns the chunks to send

pub fn next_tx_chunk(&mut self) -> Option<SyncChunk>

Get next chunk to send (if any)

pub fn queue_chunks(&mut self, chunks: Vec<SyncChunk>)

Queue chunks for sending

pub fn has_pending_tx(&self) -> bool

Check if there are chunks to send

pub fn process_received( &mut self, chunk: SyncChunk, peer_id: &NodeId, ) -> Option<Vec<CrdtOperation>>

Process a received chunk

Returns decoded operations if message is complete

pub fn ack_send(&mut self)

Acknowledge completion of send

pub fn reset(&mut self)

Reset protocol state (e.g., on reconnection)

pub fn reset_peer(&mut self, peer_id: &NodeId)

Reset sync state for a specific peer

pub fn tick(&mut self)

Run periodic maintenance

pub fn stats(&self) -> SyncStats

Get sync statistics