Struct RetryController 

pub struct RetryController<'request, 'binding> { /* private fields */ }

Non-cloneable owner of one request’s retry state and idempotency intent.

use cloud_sdk::retry::RetryController;

fn duplicate(owner: RetryController<'_, '_>) {
    let _second = owner.clone();
}

Implementations

impl<'request, 'binding> RetryController<'request, 'binding>

pub fn new( subject: RetrySubject<'request, 'binding>, idempotency: Option<IdempotencyBinding<'binding>>, policy: RetryPolicy, started: MonotonicInstant, ) -> Result<Self, RetryPolicyError>

Creates the sole retry owner for one initial request attempt.

The moved intent is bound to the initial fingerprint. Mutating requests with more than one admitted attempt require a fresh intent.

pub const fn attempts(&self) -> u16

Returns attempts already consumed, including the initial attempt.

pub const fn cumulative_delay(&self) -> MonotonicDuration

Returns caller-requested delay already charged to this owner.

pub fn decide_retry<'controller, 'replay, 'subject>( &'controller mut self, event: RetryEvent, replay: RetrySubject<'replay, 'subject>, delay: MonotonicDuration, now: MonotonicInstant, ) -> Result<RetryDecision<'controller, 'replay, 'subject>, RetryPolicyError>

Decides whether one exact replay may execute.

delay includes caller-selected backoff and jitter. This function does not read clocks, sleep, execute transport, or classify provider errors.

Trait Implementations

impl Debug for RetryController<'_, '_>

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

Formats the value using the given formatter.