Struct ActionPoller 

pub struct ActionPoller { /* private fields */ }

Single-owner bounded action workflow driver.

use cloud_sdk::action_polling::ActionPoller;
fn duplicate(driver: ActionPoller) {
    let _copy = driver.clone();
}

Implementations

impl ActionPoller

pub const fn new( limits: ActionPollLimits, progress_policy: ProgressPolicy, started: MonotonicInstant, ) -> Self

Creates a workflow without reading a clock or issuing a request.

pub const fn observations(&self) -> u32

Returns accepted provider observations.

pub const fn cumulative_delay(&self) -> MonotonicDuration

Returns cumulative delay selected by backoff.

pub const fn is_terminal(&self) -> bool

Reports whether no further request can be admitted.

pub fn next_request( &mut self, control: PollControl, now: MonotonicInstant, ) -> Result<PollRequestStep, ActionPollError>

Admits, delays, cancels, or times out the next request.

pub fn observe<E, B>( &mut self, update: ActionUpdate<E>, progress: ProgressObservation, rate_limit: Option<RateLimit>, provider_time: ProviderTimeObservation, now: MonotonicInstant, backoff: &mut B, ) -> Result<ActionPollStep<E>, ActionObserveError<B::Error>>

where B: PollBackoff,

Accepts exactly one response for the last admitted request.

Trait Implementations

impl Debug for ActionPoller

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

Formats the value using the given formatter.