Struct AgentBuilder 

pub struct AgentBuilder { /* private fields */ }

Agent builder

Implementations

impl AgentBuilder

pub fn new(provider: Box<dyn Provider>) -> Self

pub fn system_prompt(self, prompt: impl Into<String>) -> Self

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

pub fn max_tokens(self, tokens: u32) -> Self

pub fn context_size(self, context_size: Option<u32>) -> Self

Override provider-inferred context window size.

pub fn think(self, enabled: bool) -> Self

pub fn approve_mode(self, mode: ApproveMode) -> Self

pub fn tool(self, tool: Arc<dyn Tool>) -> Self

pub fn tools(self, tools: Vec<Box<dyn Tool>>) -> Self

Add multiple tools

pub fn tools_with_provider(self, tools: Vec<Box<dyn Tool>>) -> Self

Add multiple tools with provider support

pub fn event_tx(self, tx: Sender<AgentEvent>) -> Self

Set external event sender for streaming events

pub fn skills(self, skills: Vec<Skill>) -> Self

Add skills

pub fn profile(self, profile: PromptProfile) -> Self

Set prompt profile

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

Set project overview

pub fn memory(self, summary: impl Into<String>) -> Self

Set memory summary

pub fn project_path(self, path: PathBuf) -> Self

Set project path (for dynamic tool injection like CodeGraph)

pub fn proxy_executor( self, executor: Arc<dyn ProxyToolExecutor>, tool_defs: Vec<ProxyToolDef>, ) -> Self

设置代理工具执行器

Example

use std::sync::Arc;
use serde_json::json;
use matrixcode_core::tools::toolproxy::{ProxyToolExecutor, ProxyToolDef};

let executor = Arc::new(MyProxyExecutor);
let tool_def = ProxyToolDef::new("image_search", "搜索图片", json!({...}))
    .with_priority(true);

builder.proxy_executor(executor, vec![tool_def])

pub fn build(self) -> Agent

pub fn mcp_registry(self, registry: Arc<RwLock<McpToolRegistry>>) -> Self

设置 MCP 工具注册表

Example

use std::sync::Arc;
use matrixcode_core::mcp::McpToolRegistry;

let registry = Arc::new(tokio::sync::RwLock::new(McpToolRegistry::new()));
builder.mcp_registry(registry)

pub fn pending_input_rx(self, rx: Receiver<String>) -> Self

设置实时追加消息接收器

允许在 Agent 处理过程中接收新消息，实现实时追加功能。

Example

let (pending_tx, pending_rx) = tokio::sync::mpsc::channel::<String>(100);
builder.pending_input_rx(pending_rx)