pub struct InboundContext {
pub src_peer: Option<PeerId>,
pub wire_req_id: Option<u64>,
pub arrival_ns: Option<u64>,
pub remaining_deadline_ns: Option<u64>,
}Expand description
Per-ExecId context captured at inbound envelope delivery.
Replaces the four parallel envelope_* HashMaps with one struct
of optional fields. Components access this through
RuntimeResourceRef::inbound.
Fields§
§src_peer: Option<PeerId>Source peer of the inbound envelope, if known. RX gates
(PeerHealthGateRx, BackoffGateRx) filter on this.
wire_req_id: Option<u64>Inbound wire-correlation token. wire.Send reuses this when
forwarding inside a chain instead of minting a fresh one.
None when the envelope was not part of a request/response
chain.
arrival_ns: Option<u64>Arrival timestamp (engine ns). wire.Send subtracts this from
now_ns for Dapper-style elapsed-time accounting.
remaining_deadline_ns: Option<u64>Remaining deadline propagated by the sender. wire.Send carries
this forward (minus elapsed) instead of re-estimating from RTT.
Trait Implementations§
Source§impl Clone for InboundContext
impl Clone for InboundContext
Source§fn clone(&self) -> InboundContext
fn clone(&self) -> InboundContext
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for InboundContext
impl Debug for InboundContext
Source§impl Default for InboundContext
impl Default for InboundContext
Source§fn default() -> InboundContext
fn default() -> InboundContext
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for InboundContext
impl RefUnwindSafe for InboundContext
impl Send for InboundContext
impl Sync for InboundContext
impl Unpin for InboundContext
impl UnsafeUnpin for InboundContext
impl UnwindSafe for InboundContext
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> ErasedComponent for T
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request