Struct HeartbeatSender 

pub struct HeartbeatSender { /* private fields */ }

In-memory heartbeat-sender state.

Implementations

impl HeartbeatSender

pub fn new(interval: Duration) -> Arc<Self>

pub fn interval(&self) -> Duration

pub fn add_peer(&self, addr: &Address)

Add a peer to the rotation.

pub fn remove_peer(&self, addr: &Address)

pub fn peer_count(&self) -> usize

pub fn due_peers(&self, now: Instant) -> Vec<Address>

Run one tick — return the addresses whose last_tick is older than interval. The caller emits a heartbeat PDU to each and then calls Self::record_tick.

pub fn record_tick(&self, addr: &Address, now: Instant)

Bump the per-peer last-tick to now and increment the counter. No-op if the peer is unknown.

pub fn ticks_per_peer(&self) -> Vec<(String, u64)>

Snapshot of (peer-address-string, ticks-emitted).

Trait Implementations

impl Default for HeartbeatSender

fn default() -> HeartbeatSender

Returns the “default value” for a type.