String 返回状态的可读名称

Error 实现 error 接口

读取缓存

按键获取字符串值。

同步调用模型，自带熔断降级 @param prompt 提示词 @param forceModel 指定模型名称（为 null 时自动路由） @return 模型响应

流式调用模型，自带熔断降级

Chat 发送对话请求并返回完整响应

返回 (doc_id, bm25_score) 降序。

添加一个追踪节点（Span）

判断工具是否已注册

获取工具名称（唯一标识）

获取工具描述（供 LLM 理解工具用途）

写入缓存（带过期时间）

writeSSE 写入一条 SSE 事件

NewAppError 创建一个新的应用错误

轻量归一化：用于辅助相似度与展示。

在线程池中执行同步 Milvus SDK 调用，避免阻塞事件循环。

返回模型生成的文本。

Execute 执行工具调用，接受 JSON 格式的参数字符串，返回执行结果

Name 返回客户端标识名称

按固定字符窗口切片（近似 token 长度）。

transitionTo 执行状态转换（调用前必须持有锁）

Allow 判断当前是否允许请求通过。 返回 true 表示允许，返回 false 表示熔断器打开，应拒绝请求。

Name 返回工具的唯一标识名称

Register 注册一个工具。如果同名工具已存在则返回错误。

Search 语义搜索相关记忆

Split 将文档内容分割为多个块

结束追踪

执行 ReAct 循环 @param query 用户查询 @param context 附加上下文（如 RAG 检索结果） @param availableTools 可用工具列表 @param traceId 追踪 ID @return 包含思考过程的完

getBreaker 获取指定模型的熔断器

获取指定子集的工具 @param toolNames 工具名称列表，为 null 则返回全部

purpose 示例：\"react\"、\"planner\"、\"reflection\" 返回对象需实现 async def acomplete(messages, **kwargs) -> str

记录请求失败

路由并执行工具调用 @param toolName 工具名称 @param argsJson 参数 JSON 字符串 @return 执行结果

Clear 清除指定会话的所有记忆

Insert 插入向量记录

ListAvailableTools 返回注册中心中所有可用工具的名称

Load 加载指定会话的记忆列表

NewCircuitBreaker 创建一个新的三态熔断器

ProcessMessage 处理用户消息的完整流程： 意图识别 → 加载上下文 → 策略路由 → 执行 Agent → 保存记忆 → 返回结果

RecordFailure 记录一次失败的请求。 在关闭状态下连续失败达到阈值将触发熔断；在半开状态下任何失败立即重新打开。

RecordSuccess 记录一次成功的请求。 在半开状态下，连续成功达到阈值后将恢复到关闭状态。

Save 保存一条记忆

SaveMessage 保存用户或助手的消息到记忆系统。 短期记忆同步写入，长期记忆异步写入（不阻塞主流程）。

Shutdown 优雅关闭追踪器，确保所有 Span 都已导出

将查询编码为向量；无编码器时使用词袋哈希近似向量。

从模型输出中提取 JSON 对象。

使用 pypdf 抽取文本。

无嵌入时的回退：基于分词的 Jaccard 相似度。

简单中英文分词：按非字母数字 Unicode 切分。

限制内存中 trace 数量。

添加一条消息到对话历史 @param conversationId 会话 ID @param role 消息角色（user / assistant） @param content 消息内容

将检索结果格式化为 Prompt 上下文

生成工具描述列表（供 LLM Prompt 使用）

清空索引。

基础四则运算备用方案

执行工具逻辑；子类实现具体行为。

fallback 当 LLM 不可用或解析失败时的兜底策略

findFallback 在主模型不可用时寻找备选模型。 按模型名称排序选择第一个未熔断的模型。

获取会话的完整对话历史

读取会话全部消息（按时间顺序）。

handleChat 处理普通对话