pub struct InvocationResourceLease<R>where
R: DeviceRuntime,{ /* private fields */ }Expand description
Exact prepared batch node/provider invocation authority. No device command has been submitted at this layer; dropping it performs the typed definitely-not-submitted participant-flight rollback.
Implementations§
Source§impl<R> InvocationResourceLease<R>where
R: DeviceRuntime,
impl<R> InvocationResourceLease<R>where
R: DeviceRuntime,
pub fn node_id(&self) -> &NodeId
pub const fn batch_invocation_id(&self) -> BatchInvocationId
pub fn batch_step_id(&self) -> BatchStepId
pub fn participant_count(&self) -> u32
pub fn prepared_participant_count(&self) -> u32
pub fn coordinator_id(&self) -> LogicalAdmissionCoordinatorId
pub fn participants( &self, ) -> impl ExactSizeIterator<Item = &Arc<AdmittedSequenceResources<R>>>
pub fn participant_frames(&self) -> &[StepParticipantFrameAssignment]
pub fn step_resources(&self) -> &Arc<StepResourceLease<R>> ⓘ
pub fn backing_slices(&self) -> &[LogicalBackingSliceAuthority]
pub fn logical_capacity(&self) -> Option<&LogicalBatchCapacityLease>
pub fn work_shape(&self) -> &BatchWorkShape
pub fn claimed_backing(&self) -> &ClaimedBackingTransaction
pub fn plan_evidence(&self) -> TrustedPlanRuntimeEvidence
Auto Trait Implementations§
impl<R> !RefUnwindSafe for InvocationResourceLease<R>
impl<R> !UnwindSafe for InvocationResourceLease<R>
impl<R> Freeze for InvocationResourceLease<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: Freeze,
Vec<Arc<AdmittedSequenceResources<R>>>: Freeze,
Arc<StepResourceLease<R>>: Freeze,
impl<R> Send for InvocationResourceLease<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: Send,
Vec<Arc<AdmittedSequenceResources<R>>>: Send,
Arc<StepResourceLease<R>>: Send,
impl<R> Sync for InvocationResourceLease<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: Sync,
Vec<Arc<AdmittedSequenceResources<R>>>: Sync,
Arc<StepResourceLease<R>>: Sync,
impl<R> Unpin for InvocationResourceLease<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: Unpin,
Vec<Arc<AdmittedSequenceResources<R>>>: Unpin,
Arc<StepResourceLease<R>>: Unpin,
impl<R> UnsafeUnpin for InvocationResourceLease<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: UnsafeUnpin,
Vec<Arc<AdmittedSequenceResources<R>>>: UnsafeUnpin,
Arc<StepResourceLease<R>>: UnsafeUnpin,
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