Struct PeerState 

pub struct PeerState {
    pub info: PeerInfo,
    pub last_clock: VectorClock,
    pub connection_state: PeerConnectionState,
    pub last_seen: Option<Instant>,
    pub pending_acks: HashMap<u64, Instant>,
    pub rtt_estimate: Option<Duration>,
}

Tracked state for a connected peer.

Fields

info: PeerInfo

Peer information

last_clock: VectorClock

Last known clock from this peer

connection_state: PeerConnectionState

Connection state

last_seen: Option<Instant>

Last message received timestamp

pending_acks: HashMap<u64, Instant>

Pending acknowledgments (message_id -> sent_time)

rtt_estimate: Option<Duration>

Round-trip time estimate (in milliseconds)

Implementations

impl PeerState

pub fn new(info: PeerInfo, clock: VectorClock) -> Self

Create a new peer state.

pub fn touch(&mut self)

Update the last seen time.

pub fn is_stale(&self, timeout: Duration) -> bool

Check if the peer is considered stale (no recent activity).

pub fn expect_ack(&mut self, message_id: u64)

Record that we sent a message requiring acknowledgment.

pub fn receive_ack(&mut self, message_id: u64)

Record that we received an acknowledgment.

Trait Implementations

impl Clone for PeerState

fn clone(&self) -> PeerState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PeerState

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

Formats the value using the given formatter.