Struct RequestTracker 

pub struct RequestTracker { /* private fields */ }

Monotonically-increasing token minter + in-flight tracker.

Implementations

impl RequestTracker

pub fn new() -> Self

Construct fresh with token counter at 0.

pub fn mint_token(&mut self) -> CommandId

Mint a fresh correlation token (used by CorrelateTag + wire::Send to identify the round trip).

pub fn register_in_flight( &mut self, wire_req_id: u64, started_at_ns: u64, target_site: NodeSiteId, chain: Option<ChainContext>, ttl_ns: NonZeroU64, parked_op: Option<CommandId>, )

Record an outbound wire round-trip’s dispatch-time bookkeeping. wire_req_id is the token returned by Self::mint_token; reused on the response side to match. ttl_ns is the maximum age the entry will survive before the tracker considers it stale (typed as NonZeroU64 so callers cannot accidentally register an entry that never expires, which was the only failure mode the RequestTracker.in_flight map had as an unbounded resource). parked_op is the CommandId of the originator’s local op parked waiting for the chain response; None for entries registered outside an async-suspension context.

pub fn observe_response( &mut self, wire_req_id: u64, now_ns: u64, ) -> Option<RoundTripSample>

Pop the in-flight entry for a landing response and surface the elapsed-time sample the RTT tracker should observe. Returns None when no matching in-flight entry exists (the response is unsolicited, duplicate, or fired before the tracker was populated).

pub fn peek(&self, wire_req_id: u64) -> Option<&InFlightSend>

Read-only peek at an in-flight entry without consuming it.

pub fn in_flight_count(&self) -> usize

Count of currently in-flight round trips.

pub fn drain_stale(&mut self, now_ns: u64) -> Vec<(u64, InFlightSend)>

Drain in-flight entries whose per-entry expires_at_ns has passed (entries with expires_at_ns == 0 never expire on age). Returns the dropped entries so the engine can emit EngineStep::WireTimeout and fail any parked CommandId.

Trait Implementations

impl Default for RequestTracker

fn default() -> RequestTracker

Returns the “default value” for a type.