pub struct InFlightSend {
pub started_at_ns: u64,
pub expires_at_ns: u64,
pub target_site: NodeSiteId,
pub chain: Option<ChainContext>,
pub parked_op: Option<CommandId>,
}Expand description
Bookkeeping for a wire round-trip in flight.
Fields§
§started_at_ns: u64Engine-clock timestamp when the send was dispatched.
expires_at_ns: u64Engine-clock timestamp at which this entry should be evicted as timed-out. Zero means “no TTL — never evict on age”.
target_site: NodeSiteIdDestination logical site, derived from the resolved PeerId.
chain: Option<ChainContext>Optional compiler-stamped chain context.
parked_op: Option<CommandId>CommandId of the originator’s local op parked waiting for
the chain’s response. When drain_stale evicts on TTL, the
engine routes a WireTimeout failure through this CommandId
so the parked continuation unsticks. None for entries
registered outside an async-suspension context (e.g.
fire-and-forget Sends).
Trait Implementations§
Source§impl Clone for InFlightSend
impl Clone for InFlightSend
Source§fn clone(&self) -> InFlightSend
fn clone(&self) -> InFlightSend
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 moreimpl Copy for InFlightSend
Auto Trait Implementations§
impl Freeze for InFlightSend
impl RefUnwindSafe for InFlightSend
impl Send for InFlightSend
impl Sync for InFlightSend
impl Unpin for InFlightSend
impl UnsafeUnpin for InFlightSend
impl UnwindSafe for InFlightSend
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