Struct TimeoutNode 

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

Node wrapper that adds timeout enforcement

Wraps an inner node and enforces a maximum execution duration. If the inner node does not complete within run_timeout, the execution is cancelled and a [JunctureError::node_timeout] is returned.

Implementations

impl<S: State> TimeoutNode<S>

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

Create a new timeout node

Arguments

• inner - The node to wrap
• policy - Timeout policy governing timeout behavior

Trait Implementations

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

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

Formats the value using the given formatter.

impl<S: State + Clone> Node<S> for TimeoutNode<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.