Struct BasicAgent 

pub struct BasicAgent<T: AgentDeriveT> { /* private fields */ }

Wrapper type for Basic executor

Implementations

impl<T: AgentDeriveT> BasicAgent<T>

pub fn new(inner: T) -> Self

Trait Implementations

impl<T: AgentDeriveT> AgentDeriveT for BasicAgent<T>

Implement AgentDeriveT for the wrapper by delegating to the inner type

type Output = <T as AgentDeriveT>::Output

The output type this agent produces

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

Get the agent’s description

fn output_schema(&self) -> Option<Value>

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

Get the agent’s name

fn tools(&self) -> Vec<Box<dyn ToolT>>

Get the tools available to this agent

impl<T: AgentDeriveT> AgentExecutor for BasicAgent<T>

Implementation of AgentExecutor for the BasicExecutorWrapper

type Output = BasicAgentOutput

type Error = BasicExecutorError

fn config(&self) -> ExecutorConfig

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task, context: Arc<Context>, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + Send + 'async_trait>>

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

fn execute_stream<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 Task, context: Arc<Context>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<Self::Output, Self::Error>> + Send>>, Self::Error>> + Send + 'async_trait>>

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

impl<T> AgentHooks for BasicAgent<T>

where T: AgentDeriveT + AgentHooks + Send + Sync + 'static,

fn on_agent_create<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Hook called when builder creates a new instance of BaseAgent

fn on_run_start<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task: &'life1 Task, ctx: &'life2 Context, ) -> Pin<Box<dyn Future<Output = HookOutcome> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when the Agent Execution is Triggered, Ability to Abort is Given for users

fn on_run_complete<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, task: &'life1 Task, result: &'life2 Self::Output, ctx: &'life3 Context, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Called when the Agent Execution is Completed

fn on_turn_start<'life0, 'life1, 'async_trait>( &'life0 self, turn_index: usize, ctx: &'life1 Context, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when an executor turn is started, useful for multi-turn Executors like ReAct

fn on_turn_complete<'life0, 'life1, 'async_trait>( &'life0 self, turn_index: usize, ctx: &'life1 Context, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when an executor turn is completed, useful for multi-turn Executors like ReAct

fn on_tool_call<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tool_call: &'life1 ToolCall, ctx: &'life2 Context, ) -> Pin<Box<dyn Future<Output = HookOutcome> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn on_tool_start<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tool_call: &'life1 ToolCall, ctx: &'life2 Context, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called before executing the tool

fn on_tool_result<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tool_call: &'life1 ToolCall, result: &'life2 ToolCallResult, ctx: &'life3 Context, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Called post execution of tool with results

fn on_tool_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tool_call: &'life1 ToolCall, err: Value, ctx: &'life2 Context, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called if the execution of the tool failed

fn on_agent_shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when an Actor Agent post-shutdown, This has no effect on DirectAgent, It only works for ActorBased Agents

impl<T: AgentDeriveT> Clone for BasicAgent<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug + AgentDeriveT> Debug for BasicAgent<T>

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

Formats the value using the given formatter.

impl<T: AgentDeriveT> Deref for BasicAgent<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.