Struct SyncTracker 

pub struct SyncTracker { /* private fields */ }

Available on crate feature sync only.

Sync tracker state (each endpoint maintains this)

Tracks version numbers for synchronization:

• current_num: Version of current local state
• last_sent_num: Version of last state we sent to peer
• last_acked: Highest version our peer acknowledged receiving
• peer_state_num: Highest version we’ve received from peer

Implementations

impl SyncTracker

pub fn new() -> Self

Create a new sync tracker

pub fn with_initial_version(version: u64) -> Self

Create a tracker with initial state

pub fn current_version(&self) -> u64

Get current local state version

pub fn last_sent_version(&self) -> u64

Get last sent version

pub fn last_acked_version(&self) -> u64

Get highest version acked by peer

pub fn peer_version(&self) -> u64

Get highest version received from peer

pub fn has_pending_updates(&self) -> bool

Check if we have pending updates to send

pub fn needs_ack(&self) -> bool

Check if we need to send an ack

pub fn is_synchronized(&self) -> bool

Check if the state is in sync with peer

pub fn bump_version(&mut self) -> u64

Bump local state version (call when local state changes)

pub fn record_sent(&mut self, sent_version: u64)

Record that we sent a message

Returns the version number that was marked as sent.

pub fn process_incoming(&mut self, msg: &SyncMessage) -> bool

Process an incoming sync message

Updates:

• peer_state_num from the sender’s current version
• last_acked from the sender’s ack field

Returns true if the message contained new state (not just an ack).

pub fn create_message(&self, diff: Vec<u8>, base_state_num: u64) -> SyncMessage

Create a sync message with current state info

The caller should fill in the diff payload.

pub fn create_ack(&self) -> SyncMessage

Create an ack-only message

pub fn reset(&mut self)

Reset the tracker to initial state

pub fn diff_base_version(&self) -> u64

Get the base state number that should be used for diff computation

This is the last version we know the peer has acknowledged.

Trait Implementations

impl Clone for SyncTracker

fn clone(&self) -> SyncTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncTracker

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

Formats the value using the given formatter.

impl Default for SyncTracker

fn default() -> SyncTracker

Returns the “default value” for a type.