Struct PendingAsync

Source

pub struct PendingAsync {
    pub op_ref: OpRef,
    pub exec_id: ExecId,
    pub output_sites: Vec<NodeSiteId>,
    pub deadline_ns: Option<u64>,
}

Expand description

Bookkeeping for an Op suspended on a CommandId per docs/ENGINE.md §9.1. Stored in Engine.pending_async, keyed by CommandId.

Fields§

§op_ref: OpRef

The Op that’s suspended.

§exec_id: ExecId

The execution this suspension belongs to.

§output_sites: Vec<NodeSiteId>

Output sites the Op declared. Populated when the CommandId completes with values.

§deadline_ns: Option<u64>

Absolute deadline (scheduler.now_ns() clock) past which the suspension expires. None means “no engine-side deadline” - the Op runs until the transport reports completion or failure. Phase 5 of the poll cycle scans pending suspensions each tick and fails any whose deadline has passed via the existing OpFailed path.

Auto Trait Implementations§

§

PendingAsync

Struct PendingAsync Copy item path

Fields§

Auto Trait Implementations§

impl Freeze for PendingAsync

impl RefUnwindSafe for PendingAsync

impl Send for PendingAsync

impl Sync for PendingAsync

impl Unpin for PendingAsync

impl UnsafeUnpin for PendingAsync

impl UnwindSafe for PendingAsync

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> 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> 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<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 PendingAsync

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>,

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>,

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