Struct RetryingNode 

pub struct RetryingNode<S: State> { /* private fields */ }

Node wrapper that adds retry behavior

Wraps an inner node and retries execution according to the provided retry policy when the inner node fails.

Implementations

impl<S: State> RetryingNode<S>

pub fn new(inner: Arc<dyn Node<S>>, policy: RetryPolicy) -> Self

Create a new retrying node

Arguments

• inner - The node to wrap
• policy - Retry policy governing retry behavior

Trait Implementations

impl<S: State> Debug for RetryingNode<S>

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

Formats the value using the given formatter.

impl<S: State + Clone> Node<S> for RetryingNode<S>

fn call( &self, state: &S, config: &RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Command<S>, JunctureError>> + Send + '_>>

Execute the node logic

fn name(&self) -> &str

Get the node name

fn call_arc( &self, state: Arc<S>, config: &RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Command<S>, JunctureError>> + Send + '_>>

Execute node logic with Arc<S> to avoid O(N) state clone.