Struct RttTrackerEntry

Source

pub struct RttTrackerEntry {
    pub site_stats: RttEma,
    pub per_edge_stats: HashMap<EdgeKey, RttEma>,
    pub reported_outgoing: HashMap<(NodeSiteId, ChainId), RttEma>,
    pub phi_accrual: PhiAccrualState,
    pub last_seen_at_ns: u64,
    pub last_updated_at_ns: u64,
    pub last_phi_state: PhiState,
}

Expand description

One AddressBook-side entry per logical site we’ve ever observed.

Fields§

§site_stats: RttEma

Aggregate Jacobson over ALL round-trips to this site, any context. Fed by data plane, control plane, handshakes, anything using Engine::wire_send_tracked.

§per_edge_stats: HashMap<EdgeKey, RttEma>

Per-(chain, hop) refinement specific to this site.

§reported_outgoing: HashMap<(NodeSiteId, ChainId), RttEma>

Reverse-path piggyback: this site told us about ITS outgoing edges in chains, indexed by (next-hop, chain_id). Lets a chain originator compose a multi-hop budget from one entry per direct neighbor.

§phi_accrual: PhiAccrualState

φ-accrual per direct neighbor.

§last_seen_at_ns: u64

Timestamp of the most recent wire round-trip with this site, nanoseconds since the engine clock epoch.

§last_updated_at_ns: u64

Timestamp of the most recent EMA update.

§last_phi_state: PhiState

-v - last φ state surfaced by RttTracker::scan_phi. The scan emits a transition only when the state changes so subscribers don’t get a Suspect event every poll cycle while the site stays silent.

RttTrackerEntry

Struct RttTrackerEntry Copy item path

Fields§

Trait Implementations§

impl Default for RttTrackerEntry

fn default() -> RttTrackerEntry

Auto Trait Implementations§

impl Freeze for RttTrackerEntry

impl RefUnwindSafe for RttTrackerEntry

impl Send for RttTrackerEntry

impl Sync for RttTrackerEntry

impl Unpin for RttTrackerEntry

impl UnsafeUnpin for RttTrackerEntry

impl UnwindSafe for RttTrackerEntry

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> ErasedComponent for Twhere T: Any + Send + Sync,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct RttTrackerEntry

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> ErasedComponent for T
where T: Any + Send + Sync,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,