Struct PermitAttempt 

pub struct PermitAttempt<'permit, 'request, 'fingerprint> { /* private fields */ }

One in-flight attempt. Dropping it records uncertain delivery.

The prepared request cannot be extracted from this capability.

use cloud_sdk::operation::PermitAttempt;

fn extract(attempt: &PermitAttempt<'_, '_, '_>) {
    let _ = attempt.prepared();
}

Implementations

impl<'permit, 'request, 'fingerprint> PermitAttempt<'permit, 'request, 'fingerprint>

pub fn complete(self, phase: DeliveryPhase) -> PermitDisposition

Completes a manually driven attempt with conservative delivery state.

NotSent is sound only when a delivery-aware transport boundary proves that no request bytes reached the peer. Unknown state must be reported as PossiblySent; ordinary callers should prefer the execute methods.

pub fn complete_applied(self) -> PermitDisposition

Marks a successful checked provider response and spends authority.

pub fn reject_authorization<E>( self, error: ExecutionPermitError, response_storage: &mut [u8], response_header_storage: &mut [u8], ) -> PermitExecutionError<E>

Rejects this in-flight attempt before transport dispatch.

Provider wrappers use this after validating request-bound evidence with the same clock sample supplied to the generic permit check.

pub fn execute_blocking<'buffer, T, C>( self, clock: &C, transport: &T, response_storage: &'buffer mut [u8], response_header_storage: &'buffer mut [u8], ) -> Result<CheckedResponseGuard<'buffer>, PermitExecutionError<T::Error>>

where T: BlockingAuthenticatedTransport + BoundTransport, T::Error: DeliveryClassified, C: PermitClock + ?Sized,

Executes once through a delivery-classified blocking transport.

pub fn execute_async<'transport, 'buffer, T, C>( self, clock: &'transport C, transport: &'transport T, response_storage: &'buffer mut [u8], response_header_storage: &'buffer mut [u8], ) -> impl Future<Output = Result<CheckedResponseGuard<'buffer>, PermitExecutionError<T::Error>>> + 'transport

where T: AsyncAuthenticatedTransport + BoundTransport, T::Error: DeliveryClassified, C: PermitClock + Sync + ?Sized, 'request: 'transport, 'permit: 'transport, 'buffer: 'transport,

Executes once through a delivery-classified Send-async transport.

pub fn execute_local_async<'transport, 'buffer, T, C>( self, clock: &'transport C, transport: &'transport T, response_storage: &'buffer mut [u8], response_header_storage: &'buffer mut [u8], ) -> impl Future<Output = Result<CheckedResponseGuard<'buffer>, PermitExecutionError<T::Error>>> + 'transport

where T: LocalAsyncAuthenticatedTransport + BoundTransport, T::Error: DeliveryClassified, C: PermitClock + ?Sized, 'request: 'transport, 'permit: 'transport, 'buffer: 'transport,

Executes once through a delivery-classified local-async transport.

Trait Implementations

impl Debug for PermitAttempt<'_, '_, '_>

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

Formats the value using the given formatter.

impl Drop for PermitAttempt<'_, '_, '_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.