Struct DefaultContext

pub struct DefaultContext { /* private fields */ }

Implementations

impl DefaultContext

pub fn from_executor<T: Into<Arc<dyn ToolExecutor>>>( executor: T, ) -> DefaultContext

Create a new context with a custom executor

pub fn with_stop_on_assistant(&mut self, stop: bool) -> &mut Self

If set to true, the agent will stop if the last message is from the assistant (i.e. no new tool calls, summaries or user messages)

pub fn with_message_history( &mut self, backend: impl MessageHistory + 'static, ) -> &mut Self

pub async fn with_existing_messages<I: IntoIterator<Item = ChatMessage>>( &mut self, message_history: I, ) -> Result<&mut Self>

Build a context from an existing message history

Errors

Errors if the message history cannot be extended

Panics

Panics if the inner mutex is poisoned

pub fn with_tool_feedback( &mut self, feedback: impl Into<HashMap<ToolCall, ToolFeedback>>, )

Add existing tool feedback to the context

Panics

Panics if the inner mutex is poisoned

Trait Implementations

impl AgentContext for DefaultContext

fn next_completion<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<ChatMessage>>>> + Send + 'async_trait>>

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

Retrieve messages for the next completion

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

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

Returns the messages the agent is currently completing on

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

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

Retrieve all messages in the conversation history

fn add_messages<'life0, 'async_trait>( &'life0 self, messages: Vec<ChatMessage>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Add multiple messages to the conversation history

fn add_message<'life0, 'async_trait>( &'life0 self, item: ChatMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Add a single message to the conversation history

fn exec_cmd<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 Command, ) -> Pin<Box<dyn Future<Output = Result<CommandOutput, CommandError>> + Send + 'async_trait>>

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

👎Deprecated: use executor instead

Execute a command in the tool executor

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

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

Pops the last messages up until the previous completion

LLMs failing completion for various reasons is unfortunately a common occurrence This gives a way to redrive the last completion in a generic way

fn executor(&self) -> &Arc<dyn ToolExecutor>

fn has_received_feedback<'life0, 'life1, 'async_trait>( &'life0 self, tool_call: &'life1 ToolCall, ) -> Pin<Box<dyn Future<Output = Option<ToolFeedback>> + Send + 'async_trait>>

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

Tools that require feedback or approval (i.e. from a human) can use this to check if the feedback is received

fn feedback_received<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tool_call: &'life1 ToolCall, feedback: &'life2 ToolFeedback, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

impl Clone for DefaultContext

fn clone(&self) -> DefaultContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DefaultContext

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

Formats the value using the given formatter.

impl Default for DefaultContext

fn default() -> Self

Returns the “default value” for a type.