Struct ExecutionPolicy 

pub struct ExecutionPolicy<C, T, E> { /* private fields */ }

A reusable reliability policy. Cheap to clone (shares a compiled Plan).

Implementations

impl ExecutionPolicy<(), (), ()>

pub fn builder<T, E>() -> ExecutionPolicyBuilder<T, E>

Start configuring a policy. The T/E types are inferred at the first retry(..) or execute call site.

impl<C, T, E> ExecutionPolicy<C, T, E>

pub fn circuit_state(&self) -> Option<BreakerState>

Current circuit-breaker state, or None if no breaker is configured.

impl<C, T, E> ExecutionPolicy<C, T, E>

where C: Core,

pub async fn run<F>(&self, op: F) -> Result<T, ExecutionError<E>>

where F: AsyncFnMut() -> Result<T, E>,

Run an operation that needs neither application state nor attempt metadata.

pub async fn execute<F>(&self, op: F) -> Result<T, ExecutionError<E>>

where F: AsyncFnMut(Attempt<'_>) -> Result<T, E>,

Run an operation that wants attempt metadata.

pub async fn run_with<S, F>( &self, state: &S, op: F, ) -> Result<T, ExecutionError<E>>

where S: Sync + ?Sized, F: AsyncFnMut(&S) -> Result<T, E>,

Run an operation with injected application state.

pub async fn execute_with<S, F>( &self, state: &S, op: F, ) -> Result<T, ExecutionError<E>>

where S: Sync + ?Sized, F: AsyncFnMut(&S, Attempt<'_>) -> Result<T, E>,

Run an operation with injected state and attempt metadata.

Trait Implementations

impl<C: Clone, T, E> Clone for ExecutionPolicy<C, T, E>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C: Debug, T, E> Debug for ExecutionPolicy<C, T, E>

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

Formats the value using the given formatter.