Struct PeerProtocolCounters 

pub struct PeerProtocolCounters {
    messages_sent: AtomicU64,
    acks_received: AtomicU64,
}

Minimal atomic counters for per-peer protocol conformance tracking.

Tracks the number of messages sent and acknowledgments received for a single peer. All operations are lock-free using relaxed atomic ordering.

Fields

messages_sent: AtomicU64

acks_received: AtomicU64

Implementations

impl PeerProtocolCounters

pub fn record_message_sent(&self)

Record that a message was sent to this peer.

pub fn record_ack_received(&self)

Record that an acknowledgment was received from this peer.

pub fn record_acks_received(&self, count: u64)

Record that count acknowledgments were received from this peer in a batch.

pub fn take(&self) -> (u64, u64)

Swap both counters to 0, returning accumulated values.

Each counter is swapped independently via its own atomic operation; there is no single atomic snapshot of the pair.

Trait Implementations

impl Debug for PeerProtocolCounters

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

Formats the value using the given formatter.

impl Default for PeerProtocolCounters

fn default() -> PeerProtocolCounters

Returns the “default value” for a type.