Struct PeerSyncState 

pub struct PeerSyncState {
    pub last_received_timestamp: Timestamp,
    pub sync_count: u32,
    pub bytes_sent: u64,
    pub bytes_received: u64,
    /* private fields */
}

Tracks the sync state with a specific peer

Fields

last_received_timestamp: Timestamp

Last timestamp we received from this peer

sync_count: u32

Number of successful syncs

bytes_sent: u64

Bytes sent to this peer

bytes_received: u64

Bytes received from this peer

Implementations

impl PeerSyncState

pub fn new() -> Self

Create new peer sync state

pub fn mark_sent(&mut self, key: &str, timestamp: Timestamp)

Record that we sent a key at a timestamp

pub fn last_sent_timestamp(&self, key: &str) -> Option<Timestamp>

Get the last sent timestamp for a key

pub fn needs_send(&self, key: &str, timestamp: Timestamp) -> bool

Check if we need to send this key (has newer timestamp)

pub fn reset(&mut self)

Clear all tracking (for reconnection)

Trait Implementations

impl Clone for PeerSyncState

fn clone(&self) -> PeerSyncState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PeerSyncState

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

Formats the value using the given formatter.

impl Default for PeerSyncState

fn default() -> PeerSyncState

Returns the “default value” for a type.