Struct Agent 

pub struct Agent { /* private fields */ }

Agent that orchestrates interactions between a language model and tools

Create an agent using the builder pattern:

use mixtape_core::{Agent, ClaudeSonnet4_5, Result};

#[tokio::main]
async fn main() -> Result<()> {
    let agent = Agent::builder()
        .bedrock(ClaudeSonnet4_5)
        .with_system_prompt("You are a helpful assistant")
        .build()
        .await?;

    let response = agent.run("Hello!").await?;
    println!("{}", response);
    Ok(())
}

Implementations

impl Agent

pub fn builder() -> AgentBuilder

Create a new AgentBuilder for fluent configuration

Example

use mixtape_core::{Agent, ClaudeHaiku4_5, Result};

#[tokio::main]
async fn main() -> Result<()> {
    let agent = Agent::builder()
        .bedrock(ClaudeHaiku4_5)
        .with_system_prompt("You are a helpful assistant")
        .build()
        .await?;

    let response = agent.run("Hello!").await?;
    println!("{}", response);
    Ok(())
}

impl Agent

pub fn authorizer(&self) -> &RwLock<ToolCallAuthorizer>

Get the authorizer to grant/revoke permissions.

pub async fn respond_to_authorization( &self, proposal_id: &str, response: AuthorizationResponse, ) -> Result<(), PermissionError>

Respond to an authorization request with a choice.

Use this to respond to crate::AgentEvent::PermissionRequired events.

pub async fn grant_tool_permission( &self, proposal_id: &str, tool_name: &str, scope: Scope, ) -> Result<(), PermissionError>

Grant permission to trust this tool entirely.

This saves a tool-wide grant that will auto-authorize all future calls.

pub async fn grant_params_permission( &self, proposal_id: &str, tool_name: &str, params_hash: &str, scope: Scope, ) -> Result<(), PermissionError>

Grant permission for this exact call.

This saves an exact-match grant for the specific parameters.

pub async fn authorize_once( &self, proposal_id: &str, ) -> Result<(), PermissionError>

Authorize a request once (don’t save).

pub async fn deny_authorization( &self, proposal_id: &str, reason: Option<String>, ) -> Result<(), PermissionError>

Deny an authorization request.

impl Agent

pub async fn run(&self, user_message: &str) -> Result<AgentResponse, AgentError>

Run the agent with a user message

This will execute an agentic loop, calling the model and executing tools until the model returns a final text response.

Returns an AgentResponse containing the text response, tool call history, token usage statistics, and timing information.

If a session store is configured, this will automatically load and resume the session for the current directory.

Errors

Returns AgentError which can be:

• Provider - API errors (authentication, rate limits, network issues)
• Tool - Tool execution failures
• Session - Session storage errors (if session feature enabled)
• NoResponse - Model returned no text
• MaxTokensExceeded - Response hit token limit
• ContentFiltered - Response was filtered
• ToolDenied - Tool execution was denied by user/policy

impl Agent

pub fn add_tool<T: Tool + 'static>(&mut self, tool: T)

where T::Input: Serialize,

Add a tool to the agent’s toolbox

pub fn list_tools(&self) -> Vec<ToolInfo>

List all configured tools

pub fn format_tool_input( &self, tool_name: &str, params: &Value, context: Display, ) -> Option<String>

Format tool input parameters for presentation

Returns formatted string if the tool has a custom presenter, None otherwise (caller should fall back to JSON).

pub fn format_tool_output( &self, tool_name: &str, result: &ToolResult, context: Display, ) -> Option<String>

Format tool output for presentation

Returns formatted string for the tool output.

impl Agent

pub fn add_hook(&self, hook: impl AgentHook + 'static)

Add an event hook to observe agent execution

Hooks receive notifications about agent lifecycle, model calls, and tool executions in real-time.

Example

use mixtape_core::{Agent, ClaudeSonnet4_5, AgentEvent, AgentHook};

struct Logger;

impl AgentHook for Logger {
    fn on_event(&self, event: &AgentEvent) {
        println!("Event: {:?}", event);
    }
}

let agent = Agent::builder()
    .bedrock(ClaudeSonnet4_5)
    .build()
    .await?;
agent.add_hook(Logger);

pub fn model_name(&self) -> &str

Get the model name for display

pub async fn shutdown(&self)

Gracefully shutdown the agent, disconnecting MCP servers

Call this before dropping the agent to ensure clean subprocess termination.

pub fn get_context_usage(&self) -> ContextUsage

Get current context usage information

Returns statistics about how much of the context window is being used, including the number of messages and estimated token count.

pub fn last_context_info(&self) -> Option<ContextLoadResult>

Get information about the most recently loaded context files

Returns None if run() has not been called yet.

Example

let response = agent.run("Hello").await?;

if let Some(ctx) = agent.last_context_info() {
    println!("Loaded {} context files ({} bytes)",
        ctx.files.len(), ctx.total_bytes);
    for file in &ctx.files {
        println!("  - {}", file.resolved_path.display());
    }
}