Struct AgentExecutorChain 

pub struct AgentExecutorChain { /* private fields */ }

Wraps an AgentExecutor behind the BaseChain trait.

Inputs follow the agent convention: a single input string (or any string key the agent’s planner reads). Output is produced under output.

Implementations

impl AgentExecutorChain

pub fn new(executor: Arc<AgentExecutor>) -> Self

Create an adapter around a ready-built executor.

Attach memory before wrapping (e.g. .with_memory(...)) if multi-turn state across A2A tasks is desired.

pub fn inner(&self) -> &AgentExecutor

The inner executor, for inspection or configuration.

Trait Implementations

impl BaseChain for AgentExecutorChain

fn input_keys(&self) -> Vec<&str>

Get input keys.

fn output_keys(&self) -> Vec<&str>

Get output keys.

fn invoke<'life0, 'async_trait>( &'life0 self, inputs: HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<ChainResult, ChainError>> + Send + 'async_trait>>

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

Execute the Chain.

fn name(&self) -> &str

Get Chain name.

fn invoke_with_config<'life0, 'async_trait>( &'life0 self, inputs: HashMap<String, Value>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, Value>, ChainError>> + Send + 'async_trait>>

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

Execute the Chain with a RunnableConfig.

fn stream<'life0, 'async_trait>( &'life0 self, inputs: HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<StreamToken, ChainError>> + Send>>, ChainError>> + Send + 'async_trait>>

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

Stream execute the Chain – token by token output.

fn stream_with_config<'life0, 'async_trait>( &'life0 self, inputs: HashMap<String, Value>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<StreamToken, ChainError>> + Send>>, ChainError>> + Send + 'async_trait>>

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

Stream execute the Chain with a RunnableConfig.

fn validate_inputs( &self, inputs: &HashMap<String, Value>, ) -> Result<(), ChainError>

Validate inputs.