Struct RttTracker 

pub struct RttTracker { /* private fields */ }

Runtime-owned RTT tracker.

Sits alongside super::address_book::AddressBook in the framework. Every wire round-trip the engine observes (any protocol, any chain context) feeds Self::observe_round_trip; every outgoing send queries Self::estimate_budget_ns for its deadline.

Implementations

impl RttTracker

pub fn new() -> Self

Fresh, empty tracker.

pub fn estimate_budget_ns( &self, site: NodeSiteId, chain: Option<ChainContext>, static_default_ns: u64, ) -> u64

Hierarchical fallback: per-edge → per-site → per-chain → global → static. First warm tier wins.

pub fn observe_round_trip( &mut self, site: NodeSiteId, chain: Option<ChainContext>, elapsed_ns: u64, now_ns: u64, )

Feed a round-trip sample. Updates per-site Jacobson EMA always; per-edge + per-chain when chain context is present; global prior always (with a smaller learning rate).

pub fn ingest_reported_outgoing( &mut self, from_site: NodeSiteId, next_hop: NodeSiteId, chain_id: ChainId, srtt_ns: u64, rttvar_ns: u64, sample_count: u64, )

Ingest a reverse-path piggyback report - a downstream site telling us about ITS outgoing edge to next_hop in chain chain_id.

pub fn entry(&self, site: NodeSiteId) -> Option<&RttTrackerEntry>

Read-only access to a per-site entry. Returns None when no round-trip with the site has been observed.

pub fn chain_prior(&self, chain_id: ChainId) -> Option<&RttEma>

Read-only access to the per-chain prior.

pub fn global_prior(&self) -> &RttEma

Read-only access to the global prior.

pub fn tracked_sites(&self) -> impl Iterator<Item = NodeSiteId> + '_

Snapshot of every site currently tracked.

pub fn scan_phi(&mut self, now_ns: u64) -> Vec<PhiTransition>

-v - scan φ-accrual states at the current engine clock and surface state transitions. Returns one entry per tracked site whose suspicion level changed since the last scan: PhiTransition::Suspect, Down, or Live (after a previous Suspect/Down resolves).

The tracker keeps a per-site last_phi_state ratchet so repeat scans don’t re-emit the same event every poll cycle.

Trait Implementations

impl Default for RttTracker

fn default() -> RttTracker

Returns the “default value” for a type.