Position 值对象 属性说明： - x: 横坐标（像素） - y: 纵坐标（像素） 为什么使用 frozen=True？ - 值对象应该是不可变的（Immutable） - 防止意外修改 - 可以作为字典的 key 示例：

协调者Agent 职责： 1. 管理验证规则 2. 验证对话Agent的决策 3. 作为EventBus中间件拦截决策 4. 发布验证/拒绝事件 5. 监控决策统计 使用示例： agent = CoordinatorAgen

事件总线 职责： 1. 管理事件订阅关系 2. 分发事件到对应的处理器 3. 执行中间件链 4. 记录事件日志 设计决策： - 单一数据源：所有状态变更都通过事件传递 - 类型过滤：订阅者只收到指定类型的事件 - 中间件链：

全局上下文 - 只读 存储用户信息和系统配置，整个会话期间不可修改。 属性： user_id: 用户ID user_preferences: 用户偏好 system_config: 系统配置 global_goals

会话上下文 管理对话历史、目标栈和决策历史。 属性： session_id: 会话ID global_context: 全局上下文引用 conversation_history: 对话历史 goal_stack: 目

节点定义 Agent 可通过此类定义节点的具体功能。 属性： id: 节点唯一标识 node_type: 节点类型 name: 节点名称 description: 节点描述 code: Python

领域层异常基类 用途： - 表示业务规则违反（如：start 不能为空） - 表示领域不变式违反（如：状态流转非法） 为什么继承 Exception？ - Python 标准做法 - 可以被 try-except 捕获 - 可以携带错误消息

对话Agent 职责: 1. 执行ReAct循环进行推理 2. 分解复杂目标 3. 生成决策并发布事件 4. 管理对话上下文 使用示例: agent = ConversationAgent( session_

工作流Agent 职责： 1. 管理工作流节点和边 2. 执行工作流（按拓扑顺序） 3. 发布执行状态事件 4. 处理对话Agent的决策 5. 执行工作流并返回标准结果 (Phase 16) 6. 反思执行结果并生成评估 (Phase 16

节点实例 属性： - id: 节点唯一标识 - type: 节点类型 - config: 节点配置 - lifecycle: 生命周期 - children: 子节点列表（仅GENERIC类型） - collapsed: 是否折叠（仅GENE

节点注册中心 职责： 1. 管理节点类型和Schema 2. 提供节点模板 3. 验证节点配置 4. 初始化时注册所有预定义类型 使用示例： registry = NodeRegistry() template =

工作流执行上下文 在工作流执行过程中维护的上下文信息。 字段： - workflow_id: 工作流 ID - workflow_name: 工作流名称 - available_nodes: 可用节点 ID 列表 - executed_nodes:

工作流上下文 职责： - 引用会话上下文（只读） - 存储节点输出数据 - 管理工作流变量 - 记录执行历史 设计特点： - 每个工作流有独立的上下文，相互隔离 - 支持并发执行多个工作流 - 节点间通过此上下文传递数据

工具引擎配置 属性说明： - tools_directory: 工具配置目录 - auto_reload: 是否支持自动重载 - reload_interval: 自动重载间隔（秒） - watch_for_changes: 是否监听文件变化（使用 watc

工具引擎 核心功能： 1. 启动时扫描工具目录并加载 2. 维护工具索引 3. 支持按名称/标签/分类查找 4. 支持热更新（reload） 5. 事件订阅机制

保存请求事件 当 Agent 需要进行持久化操作时，发布此事件。 Coordinator 订阅此事件进行排队和审核。 属性： request_id: 请求唯一标识 target_path: 目标路径 content: 保存内

规则定义 属性： - id: 规则唯一标识 - name: 规则名称 - description: 规则描述 - type: 规则类型（静态/动态） - priority: 优先级（越小优先级越高） - condition: 条件表达式

节点工厂 职责： 1. 根据类型和配置创建节点实例 2. 应用默认值 3. 验证配置 使用示例： factory = NodeFactory(registry) node = factory.create(NodeType.

结构化日志 属性： level: 日志级别 source: 日志来源 message: 日志消息 event_type: 事件类型 trace: 追踪上下文（可选） metadata: 元数据（

知识维护器 负责管理知识库的增删改查，以及处理工作流事件。 功能： - 添加/获取/搜索长期记忆 - 添加/获取用户偏好 - 记录成功解法和失败案例 - 处理工作流成功/失败事件

边定义 表示两个节点之间的连接关系。 属性： source_node: 源节点名称 target_node: 目标节点名称 condition: 可选的条件表达式

会话流发射器 负责将 ConversationAgent 的步骤输出转换为流式消息， 并通过异步队列传输。 属性: session_id: 会话标识 timeout: 迭代超时时间（秒）

短期记忆缓冲区 属性： - turn_id: 轮次唯一标识 - role: 角色（user/assistant/system） - content: 内容文本 - tool_refs: 工具调用引用列表 - token_usage: token 使用

会话步骤 表示 ConversationAgent 执行过程中的一个步骤。 属性: kind: 步骤类型 content: 步骤内容 metadata: 元数据 step_id: 步骤唯一标识 tim

节点定义 属性： type: 节点类型（唯一标识） name: 显示名称 description: 描述 category: 分类 input_schema: 输入Schema output_s

上下文压缩器 职责： 1. 从不同来源提取信息 2. 压缩成八段结构 3. 支持增量合并 4. 与 EvidenceStore 集成 使用示例： compressor = ContextCompressor() in

ReAct 编排器 协调 ReAct 循环的核心类，负责： - 推理（调用 LLM） - 行动（执行节点） - 观察（收集结果） - 决策（确定下一步）

工作流规划 ConversationAgent 产出的完整规划，包含节点定义和连接关系。 属性： id: 规划唯一标识 name: 规划名称 description: 规划描述 goal: 对应的用户目标

工作流动作解析器

工作流动作模型 表示工作流中 LLM 决定采取的单个动作。 字段： - type: 动作类型（必填） - node_id: 要执行的节点 ID（EXECUTE_NODE 和 ERROR_RECOVERY 时必填） - reasoning: 推理说明（可选，

决策事件 当对话Agent做出决策时发布此事件。 协调者Agent订阅此事件进行验证和记录。 属性： - decision_type: 决策类型（字符串形式） - decision_id: 决策唯一标识 - payload: 决策负载数据

并发配置 属性说明： - max_concurrent: 最大并发数（仅对话 Agent） - queue_size: 队列大小 - default_timeout: 默认超时时间（秒） - strategy: 排队策略（fifo/priority/reje

模拟保存请求

规则引擎 Facade 统一的规则引擎入口，整合决策规则、安全校验、审计等功能。 线程安全： - 使用 threading.RLock() 保护可变状态（_rules, _statistics） - 所有公共方法都是线程安全的 - 支持并发调用 valid

数据转换节点执行器 支持多种数据转换操作，包括字段映射、类型转换、数据提取等 配置参数： type: 转换类型（field_mapping, type_conversion, field_extraction等） [其他参数根据转换类型不同而不同]

上下文打包器 父 Agent 用于创建上下文包。

循环节点执行器 支持多种循环类型，包括for_each、range、while等 配置参数： type: 循环类型（for_each, range, while） [其他参数根据循环类型不同而不同]

增强版工作流对话服务（数据库持久化） 职责： 1. 维护对话历史和上下文（数据库持久化） 2. 识别用户意图和信心度 3. 应用修改到工作流 4. 提供工作流建议 5. 支持修改回滚 6. 确保对话修改只作用于 start->end 主连通子

增强规则定义 属性： - id: 规则唯一标识 - name: 规则名称 - category: 规则类别 - description: 规则描述 - condition: 条件（字符串表达式或函数） - action: 触发动作 -

SQLAlchemy Workflow Repository 实现 实现领域层定义的 WorkflowRepository Port 接口 依赖： - Session: SQLAlchemy 同步会话（依赖注入） 为什么使用同步 Session？ - 当

工具并发控制器 核心功能： 1. 槽位管理（获取/释放） 2. 排队策略（FIFO/优先级/拒绝） 3. 负载均衡（按工具类型分桶） 4. 资源管理（超时检测/取消） 5. 监控指标

压缩上下文 - 九段结构 属性： - workflow_id: 工作流ID - task_goal: 任务目标（第1段） - execution_status: 执行状态（第2段） - node_summary: 节点摘要（第3段） - decisi

内存日志存储 适用于测试和小规模场景。

工具参数定义 描述工具的输入参数要求 属性说明： - name: 参数名称 - type: 参数类型（string, number, boolean, object, array） - description: 参数描述 - required: 是

父节点 Schema 验证器 职责： - 基础字段验证（kind/name/version/executor_type） - inherit_from 语法验证 - inherit/override 块验证 - 循环继承检测 - 冲突检测 -

可靠发射器 基于 ConversationFlowEmitter 的可靠扩展版本： - 有界队列：防止内存溢出 - 溢出策略：灵活处理队列满的情况 - 消息持久化：支持将消息保存到存储后端 - 背压控制：当消费者慢时提供反压 - 重试机制：发送失败时

校验错误 属性： field: 字段路径 message: 错误消息 severity: 严重级别 suggestion: 修复建议

上下文包数据结构 用于父子 Agent 之间传递任务上下文。 Attributes: package_id: 包唯一标识符 task_description: 任务描述 prompt_version: 提示词版本

上下文快照管理器 职责： 1. 保存压缩上下文的快照 2. 按ID或工作流检索快照 3. 管理快照生命周期 使用示例： manager = ContextSnapshotManager() snapshot_id = man

增强版子任务定义 属性： id: 任务ID description: 任务描述 type: 任务类型 priority: 优先级（数字越小优先级越高） status: 任务状态 result:

实体不存在异常 用途： - 表示查询的实体不存在（如：Agent 不存在、Run 不存在） - 用于 Repository 的 get_by_id() 方法 为什么需要单独的异常类？ - 语义清晰：区分"实体不存在"和"业务规则违反" - 便于统一

表达式求值器 安全地评估条件表达式，支持： - 比较运算符：>, <, ==, !=, >=, <= - 逻辑运算符：and, or, not - 字典访问：obj['key'] - 数值、字符串、布尔值字面量 安全机制： - 白名单AST

CoordinatorAgent 主配置 统一管理所有配置参数，分为5个功能组。 使用示例： # 使用默认配置 config = CoordinatorAgentConfig() # 自定义配置 config =

节点 YAML 校验器 职责： - 加载和解析 YAML 文件 - 校验必填字段 - 校验字段类型和约束 - 校验嵌套深度 - 校验动态代码语法

Agent WebSocket 信道 管理 Agent 与客户端之间的 WebSocket 连接。

任务分类输入参数 属性说明： - start: 任务起点描述 - goal: 任务目标描述 - context: 额外上下文（可选，如历史任务、用户偏好）

上下文注入数据 属性： injection_id: 注入唯一标识 session_id: 会话 ID injection_type: 注入类型 injection_point: 注入点 content: 注入内

沙箱配置 属性： timeout_seconds: 执行超时（秒） max_memory_mb: 最大内存（MB） max_output_size: 最大输出大小（字节） allowed_imports: 允许的导入模块列表

工作流上下文 存储节点输出和工作流变量。 属性： workflow_id: 工作流ID session_context: 会话上下文引用 node_data: 节点输出数据 variables: 工作流变量

对话 Agent 主循环引擎 负责驱动 ConversationAgent 的完整生命周期， 支持 pause/resume 和事件流式处理。

全局上下文 - 只读 职责： - 存储用户信息和偏好 - 存储系统配置 - 整个会话期间不可修改 为什么设计为只读？ 1. 保护系统配置不被Agent意外修改 2. 确保多Agent共享时的一致性 3. 作为所有下层上下文的稳定基础

HTTP 请求节点执行器

保存请求结果回执 当 SaveRequest 执行完成后，返回此结果给 ConversationAgent。 属性： request_id: 原始请求 ID status: 执行状态 message: 状态消息 er

可配置规则引擎 支持从 dict/JSON/YAML 加载配置，评估保存请求。

增强规则库 职责： 1. 存储和管理规则 2. 按类别、来源、优先级查询规则 3. 评估规则并返回违规列表 4. 支持规则的CRUD操作 使用示例： repo = EnhancedRuleRepository() r

A/B 实验与灰度发布编排器

LLM 文本生成节点执行器 支持 OpenAI、Anthropic、Google 等模型

节点执行事件 Phase 35.5 修复：添加 workflow_id 字段以支持并发安全的状态监控。

节点执行器注册表 管理所有节点类型的执行器

沙箱执行器 在隔离环境中安全执行代码。 使用示例： executor = SandboxExecutor() result = executor.execute( code="result = 1 + 1\\nprint(r

工具配置加载器 功能： 1. 解析 YAML 格式的工具配置 2. 验证配置的有效性 3. 将配置转换为 Tool 实体 4. 批量加载工具配置 5. 导出 Tool 实体为 YAML 支持的入口类型（entry.type）： -

工具执行上下文 提供工具执行所需的上下文信息： - 调用者信息（Agent ID、会话 ID、工作流 ID） - 执行配置（超时、重试） - 共享变量

工具参数验证器 功能： 1. 验证必填参数 2. 验证参数类型 3. 验证枚举值 4. 检测多余参数（严格模式） 5. 填充默认值

统一定义 支持节点和工具的统一 Schema 格式。 属性： - name: 定义名称（唯一标识） - kind: 定义类型（NODE 或 TOOL） - description: 描述 - version: 版本号 - parameter

工作流聊天系统提示生成器

工作流执行开始事件

目标实体 表示一个可分解的目标，可以有子目标和依赖关系。 属性： id: 目标唯一标识 description: 目标描述 status: 目标状态 parent_id: 父目标ID（可选） depe

知识引用 表示从知识库检索到的一条相关知识。 属性： - source_id: 来源唯一标识 - title: 标题 - content_preview: 内容预览（截断） - relevance_score: 相关度分数 (0-1) -

模拟 WebSocket 连接

会话上下文 - 统一定义 职责： - 继承全局上下文（只读访问） - 管理对话历史 - 管理目标栈（支持嵌套目标） - 记录决策历史 - 跟踪上下文使用情况（token 使用和使用率） - 跟踪资源约束（时间限制、并发限制等） 生命

结构化对话摘要（八段结构） 属性： session_id: 会话ID summary_id: 摘要唯一标识 created_at: 创建时间 # 八段结构 core_goal: 核心目标 ke

监听并记录容器执行事件的监控器 属性: event_bus: 事件总线实例 max_log_size: 单容器日志最大条目数（防止内存泄漏） container_executions: workflow_id -> 执行记录列表

知识库管理器 提供知识条目的完整 CRUD 操作。

父子节点管理服务 职责： 1. 管理节点注册表 2. 创建父节点和层级结构 3. 添加/移除/移动节点 4. 折叠/展开操作 5. 查询层级结构 6. 发布层级变更事件

笔记生命周期管理器 职责： - 管理笔记状态转换 - 验证转换合法性 - 记录批准信息 - 保护已批准笔记的不可变性

分布式追踪上下文 属性： trace_id: 追踪 ID（标识整个请求链路） span_id: 当前 span ID parent_span_id: 父 span ID（可选）

追踪跨度 表示单个操作的时间记录，用于构建完整的任务链路。 属性： span_id: 跨度唯一标识 parent_span_id: 父跨度 ID（根跨度为 None） operation: 操作名称 service:

测试用决策规则桩

Coordinator 依赖装配器（Builder Pattern） 按阶段构建 Coordinator 的所有依赖，确保： - 初始化顺序正确（按依赖关系排序） - 共享实例唯一（log_collector、event_bus） - 别名完整保留（向后兼容）

Node 实体 属性说明： - id: 唯一标识符（node_ 前缀） - type: 节点类型（HTTP、Transform、Database 等） - name: 节点名称（用户可见） - config: 节点配置（JSON 格式，不同类型的节点配置不同

安全校验服务 提供文件操作、API调用、人机交互的安全验证。 使用示例： guard = SafetyGuard() guard.configure_file_security(whitelist=["/allowed"]) res

监督规则 属性： rule_id: 规则唯一标识 name: 规则名称 description: 规则描述 action: 触发时的动作 priority: 规则优先级 enabled: 是否启

对话式修改工作流输入 字段： - workflow_id: 工作流 ID - user_message: 用户消息

子节点 通用节点内部的子节点数据结构。 属性： id: 节点唯一标识 type: 节点类型 config: 节点配置 position: 节点位置（可选，用于画布显示）

对话提示监控模块 检测对话中的偏见、有害内容和稳定性问题。

节点Schema 定义节点的输入输出类型和约束。 属性： - node_type: 节点类型 - input_schema: 输入Schema（JSON Schema格式） - output_schema: 输出Schema（JSON Schema格式）

提示词使用日志记录器

SQLAlchemy Run Repository 实现 Implements: RunRepository Protocol (src/domain/ports/run_repository.py)

自描述节点验证器 提供三类验证： 1. 必需字段验证 - 确保节点定义包含所有必需字段 2. 输入输出对齐验证 - 确保输入符合参数定义，输出符合模式 3. 沙箱许可验证 - 确保代码节点在安全沙箱中执行

Tool 实体（聚合根） 属性说明： - id: 唯一标识符（tool_ 前缀） - name: 工具名称（用户可见） - description: 工具描述 - category: 工具分类 - status: 工具状态（DRAFT/TESTING