Struct ExecutorRequestStateDeferral 

pub struct ExecutorRequestStateDeferral { /* private fields */ }

Scheduler-visible proof that execution is temporarily blocked by a Request-lifetime state hazard rather than by physical capacity.

The embedded hazard evidence retains the exact plan-local coordinator and supports subscribe-before-recheck waiter registration. The request cohort is the product identity projection used by the scheduler; it must stay separate from the allocator’s internal request-authority ids.

Implementations

impl ExecutorRequestStateDeferral

pub fn new( stage: ExecutorExecutionCapacityStage, request_ids: Vec<RequestId>, hazard: RequestStateHazardDeferral, ) -> Result<Self>

pub const fn stage(&self) -> ExecutorExecutionCapacityStage

pub fn request_ids(&self) -> &[RequestId]

pub const fn hazard(&self) -> &RequestStateHazardDeferral

pub fn register_waiter(&self) -> Result<RequestStateHazardWaitRegistration>

Trait Implementations

impl Clone for ExecutorRequestStateDeferral

fn clone(&self) -> ExecutorRequestStateDeferral

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutorRequestStateDeferral

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<ExecutorRequestStateDeferral> for ExecutorExecutionDeferral

fn from(deferral: ExecutorRequestStateDeferral) -> Self

Converts to this type from the input type.

impl Serialize for ExecutorRequestStateDeferral

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.