Struct RetryNode

pub struct RetryNode<N> {
    pub inner: N,
    pub policy: RetryPolicy,
}

Wrapper node that applies a RetryPolicy on inner node failures.

Internally it will re-run the inner node up to policy.max_attempts, using backoff delays between attempts.

Fields

inner: N

Inner node to invoke.

policy: RetryPolicy

Policy controlling retry attempts and backoff.

Implementations

impl<N> RetryNode<N>

pub fn new(inner: N, policy: RetryPolicy) -> Self

Create a new retry wrapper around inner with the given policy.

Trait Implementations

impl<N: Clone> Clone for RetryNode<N>

fn clone(&self) -> RetryNode<N>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<N: Debug> Debug for RetryNode<N>

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

Formats the value using the given formatter.

impl<C, N> Node<C> for RetryNode<N>

where C: Context + RetryDelay, N: Node<C> + Clone + Send + Sync + 'static, N::Input: Clone + Send + 'static, N::Output: Send + 'static,

type Input = <N as Node<C>>::Input

Input type for the node

type Output = <N as Node<C>>::Output

Output type produced by the node

fn process<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 C, input: Self::Input, ) -> Pin<Box<dyn Future<Output = Result<Transition<Self::Output>, FloxideError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process an input value within the given context, producing a transition