Struct DeltaEncoder 

pub struct DeltaEncoder { /* private fields */ }

Manages delta encoding for all peers

Implementations

impl DeltaEncoder

pub fn new(node_id: NodeId) -> Self

Create a new delta encoder

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

Register a peer for delta tracking

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

Remove a peer

pub fn get_peer_state(&self, peer_id: &NodeId) -> Option<&PeerSyncState>

Get peer sync state

pub fn get_peer_state_mut( &mut self, peer_id: &NodeId, ) -> Option<&mut PeerSyncState>

Get mutable peer sync state

pub fn update_state(&mut self, key: &str, value_hash: u64, timestamp: Timestamp)

Update our current state with an operation

pub fn filter_for_peer( &self, peer_id: &NodeId, operations: &[CrdtOperation], ) -> Vec<CrdtOperation>

Filter operations to only those that need to be sent to a peer

pub fn mark_sent(&mut self, peer_id: &NodeId, operations: &[CrdtOperation])

Mark operations as sent to a peer

pub fn record_sent(&mut self, peer_id: &NodeId, bytes: usize)

Record bytes sent to peer

pub fn record_received( &mut self, peer_id: &NodeId, bytes: usize, timestamp: Timestamp, )

Record bytes received from peer

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

Reset sync state for a peer (e.g., on reconnection)

pub fn stats(&self) -> DeltaStats

Get sync statistics

Trait Implementations

impl Debug for DeltaEncoder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.