pub struct FenceAcquisitionRequest<'a> { /* private fields */ }Expand description
Structural binding to an already reserved acquisition; never a fresh dispatch permit.
Integration admission additionally requires durable originals, exact request semantics, actual permissions/context/unit, dependency/custody qualification and proof that this reservation has never been dispatched. Reconstructing a pending request proves none of those conditions. After interruption without that proof, reconcile instead.
Implementations§
Source§impl<'a> FenceAcquisitionRequest<'a>
impl<'a> FenceAcquisitionRequest<'a>
Sourcepub fn new(
plan: &'a OperationPlanRecord,
obligation: &'a FenceObligationRecord,
journal: &AttemptJournalRecord,
payload: &'a FenceAcquisitionPayload,
) -> Result<Self, FenceAcquisitionError>
pub fn new( plan: &'a OperationPlanRecord, obligation: &'a FenceObligationRecord, journal: &AttemptJournalRecord, payload: &'a FenceAcquisitionPayload, ) -> Result<Self, FenceAcquisitionError>
Bind original exact application bytes only after the canonical journal reserves mutation.
§Errors
Rejects changed originals, target/bytes, missing mutation or an acquisition already in observation recovery.
Sourcepub const fn plan(&self) -> &OperationPlanRecord
pub const fn plan(&self) -> &OperationPlanRecord
Read original full context/inventory/selected unit; target routing does not narrow coverage.
Sourcepub const fn obligation(&self) -> &FenceObligationRecord
pub const fn obligation(&self) -> &FenceObligationRecord
Read original purpose/fence/revisions under the retained requirement.
Sourcepub const fn payload(&self) -> &FenceAcquisitionPayload
pub const fn payload(&self) -> &FenceAcquisitionPayload
Read exact immutable application update bytes.
Read full original operation identity and spending limits.
Sourcepub const fn mutation_attempt(&self) -> u32
pub const fn mutation_attempt(&self) -> u32
Read the already consumed original mutation number.
Sourcepub fn validate_journal(
&self,
journal: &AttemptJournalRecord,
) -> Result<(), FenceAcquisitionError>
pub fn validate_journal( &self, journal: &AttemptJournalRecord, ) -> Result<(), FenceAcquisitionError>
Recheck current reservation before associating an acknowledgement; performs no IO or effects.
§Errors
Rejects changed authority, settled/replaced mutation or pending observation recovery.