Struct RunnableWithFallbacks 

pub struct RunnableWithFallbacks { /* private fields */ }

A runnable that tries a primary and falls back to alternatives on failure.

Tries the primary runnable first. If it returns an error, each fallback is tried in order until one succeeds. If all fail, the last error is returned.

Implementations

impl RunnableWithFallbacks

pub fn new( primary: Box<dyn RunnableCore>, fallbacks: Vec<Box<dyn RunnableCore>>, ) -> Self

Create a new fallback composition.

Trait Implementations

impl RunnableCore for RunnableWithFallbacks

fn invoke<'a>( &'a self, input: Value, config: Option<&'a RunnableConfig>, ) -> BoxFuture<'a, Result<Value, SynwireError>>

Invoke the runnable with a single input.

fn name(&self) -> &str

Get the runnable’s name for debugging.

fn batch<'a>( &'a self, inputs: Vec<Value>, config: Option<&'a RunnableConfig>, ) -> BoxFuture<'a, Result<Vec<Value>, SynwireError>>

Invoke on multiple inputs. Default implementation calls invoke sequentially for each input.

fn stream<'a>( &'a self, input: Value, config: Option<&'a RunnableConfig>, ) -> BoxFuture<'a, Result<BoxStream<'a, Result<Value, SynwireError>>, SynwireError>>

Stream results. Default implementation wraps invoke as a single-item stream.