Struct PlanRuntimeResources 

pub struct PlanRuntimeResources<R>
where
    R: DeviceRuntime,
{ /* private fields */ }

Unique plan-lifetime owner of the runtime, dynamic pools, maintenance authority, static buffers, capacity claims, and cleanup authority.

Implementations

impl<R> PlanRuntimeResources<R>

where R: DeviceRuntime,

pub fn deferred_cleanup_status(&self) -> DeferredDeviceCleanupStatus

pub fn create_execution_lane( &self, ) -> Result<Arc<ExecutionLane<R>>, ExecutionLaneCreationError<R::Error>>

pub fn maintain_deferred_cleanups( &self, maximum_tasks: usize, ) -> Result<DeferredDeviceCleanupMaintenanceReceipt, VNextError>

Attempts each selected cleanup owner at most once. This may block in a backend recovery call and must therefore run on a scheduler recovery thread, never on a request, admission, or destructor path.

pub fn trusted_runtime_binding( self: &Arc<Self>, ) -> Result<TrustedPlanRuntimeBinding<R>, VNextError>

pub fn maintain_for_admission_deferred( self: &Arc<Self>, deferred: &AdmissionDeferred, ) -> Result<DynamicDeferredMaintenanceOutcome, VNextError>

pub fn dynamic_pool_status( &self, ) -> Result<DynamicPoolMaintenanceStatus, VNextError>

Returns a point-in-time view of the exact dynamic pools owned by this plan. Product telemetry consumes this instead of maintaining a second allocator ledger that can drift from admission decisions.

pub fn write_dynamic_capacity_availability( &self, out: &mut Vec<CapacityAvailabilityEpoch>, ) -> Result<CapacityEpochs, VNextError>

pub fn register_capacity_waiter( self: &Arc<Self>, observed: &CapacityWaitCondition, ) -> Result<PlanCapacityWaitRegistration<R>, VNextError>

pub fn is_closing(&self) -> bool

pub fn close( resources: Arc<Self>, ) -> Result<PlanRuntimeCloseOutcome<R>, PlanRuntimeCloseFailure<R>>