Struct RouterRunnable 

pub struct RouterRunnable<I, O>
where
    I: Send + Sync + Clone + Debug + 'static,
    O: Send + Sync + Clone + Debug + 'static,
{ /* private fields */ }

A Runnable that routes to a set of Runnable based on Input['key'].

Returns the output of the selected Runnable.

Example

use agent_chain_core::runnables::{RouterRunnable, RunnableLambda, RouterInput};

let add = RunnableLambda::new(|x: i32| Ok(x + 1));
let square = RunnableLambda::new(|x: i32| Ok(x * x));

let router = RouterRunnable::new()
    .add("add", add)
    .add("square", square);

let result = router.invoke(RouterInput::new("square", 3), None)?;
assert_eq!(result, 9);

Implementations

impl<I, O> RouterRunnable<I, O>

where I: Send + Sync + Clone + Debug + 'static, O: Send + Sync + Clone + Debug + 'static,

pub fn new() -> Self

Create a new empty RouterRunnable.

pub fn from_runnables(runnables: HashMap<String, DynRunnable<I, O>>) -> Self

Create a new RouterRunnable from a HashMap of runnables.

pub fn add<R>(self, key: impl Into<String>, runnable: R) -> Self

where R: Runnable<Input = I, Output = O> + Send + Sync + 'static,

Add a runnable to the router.

pub fn with_name(self, name: impl Into<String>) -> Self

Set the name of this router.

pub fn config_specs(&self) -> Result<Vec<ConfigurableFieldSpec>, String>

Get the configurable field specs from all contained runnables.

Trait Implementations

impl<I, O> Debug for RouterRunnable<I, O>

where I: Send + Sync + Clone + Debug + 'static, O: Send + Sync + Clone + Debug + 'static,

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

Formats the value using the given formatter.

impl<I, O> Default for RouterRunnable<I, O>

where I: Send + Sync + Clone + Debug + 'static, O: Send + Sync + Clone + Debug + 'static,

fn default() -> Self

Returns the “default value” for a type.

impl<I, O> Runnable for RouterRunnable<I, O>

where I: Send + Sync + Clone + Debug + 'static, O: Send + Sync + Clone + Debug + 'static,

type Input = RouterInput<I>

The input type for this Runnable.

type Output = O

The output type for this Runnable.

fn name(&self) -> Option<String>

Get the optional name of this Runnable.

fn invoke( &self, input: Self::Input, config: Option<RunnableConfig>, ) -> Result<Self::Output>

Transform a single input into an output.

fn ainvoke<'life0, 'async_trait>( &'life0 self, input: Self::Input, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Self::Output>> + Send + 'async_trait>>

where Self: 'static + 'async_trait, 'life0: 'async_trait,

Transform a single input into an output asynchronously.

fn batch( &self, inputs: Vec<Self::Input>, config: Option<ConfigOrList>, return_exceptions: bool, ) -> Vec<Result<Self::Output>>

where Self: 'static,

Transform multiple inputs into outputs in parallel.

fn abatch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Self::Input>, config: Option<ConfigOrList>, return_exceptions: bool, ) -> Pin<Box<dyn Future<Output = Vec<Result<Self::Output>>> + Send + 'async_trait>>

where Self: 'static + 'async_trait, 'life0: 'async_trait,

Transform multiple inputs into outputs asynchronously.

fn stream( &self, input: Self::Input, config: Option<RunnableConfig>, ) -> BoxStream<'_, Result<Self::Output>>

Stream output from a single input.

fn astream( &self, input: Self::Input, config: Option<RunnableConfig>, ) -> BoxStream<'_, Result<Self::Output>>

where Self: 'static,

Stream output from a single input asynchronously.

fn get_name(&self, suffix: Option<&str>, name: Option<&str>) -> String

Get the name of this Runnable.

fn type_name(&self) -> &'static str

Get the type name of this Runnable.

fn transform<'a>( &'a self, input: BoxStream<'a, Self::Input>, config: Option<RunnableConfig>, ) -> BoxStream<'a, Result<Self::Output>>

Transform an input stream into an output stream.

fn atransform<'a>( &'a self, input: BoxStream<'a, Self::Input>, config: Option<RunnableConfig>, ) -> BoxStream<'a, Result<Self::Output>>

where Self: 'static,

Transform an input stream into an output stream asynchronously.

fn bind(self, kwargs: HashMap<String, Value>) -> RunnableBinding<Self>

where Self: Sized,

Bind arguments to this Runnable, returning a new Runnable.

fn with_config(self, config: RunnableConfig) -> RunnableBinding<Self>

where Self: Sized,

Bind config to this Runnable, returning a new Runnable.

fn with_retry( self, max_attempts: usize, wait_exponential_jitter: bool, ) -> RunnableRetry<Self>

where Self: Sized,

Create a new Runnable that retries on failure.

fn map(self) -> RunnableEach<Self>

where Self: Sized,

Return a new Runnable that maps a list of inputs to a list of outputs.

impl<I, O> Serializable for RouterRunnable<I, O>

where I: Send + Sync + Clone + Debug + Serialize + 'static, O: Send + Sync + Clone + Debug + 'static,

fn is_lc_serializable() -> bool

Is this class serializable?

fn get_lc_namespace() -> Vec<String>

Get the namespace of the LangChain object.

fn to_json(&self) -> Serialized

Serialize this object to JSON.

fn lc_secrets(&self) -> HashMap<String, String>

A map of constructor argument names to secret ids.

fn lc_attributes(&self) -> HashMap<String, Value>

List of attribute names that should be included in the serialized kwargs.

fn lc_id() -> Vec<String>

where Self: Sized,

Return a unique identifier for this class for serialization purposes.

fn lc_type_name(&self) -> &'static str

Get the type name of this object.

fn to_json_not_implemented(&self) -> Serialized

Serialize a “not implemented” object.

impl<I, O> RunnableSerializable for RouterRunnable<I, O>

where I: Send + Sync + Clone + Debug + Serialize + 'static, O: Send + Sync + Clone + Debug + Serialize + 'static,