Cell API

Cell 是 wesgine 的数据面,每租户一份,完全隔离。提供 25 个业务 Handle。


Runtime

cell.Runtime().Run(ctx, AppRunRequest{...})  // SSE 流式 Run
cell.Runtime().Chat(ctx, AppChatRequest{...}) // 同步 Chat

AppRunRequest 关键字段

字段说明
Actor★ 必填一等字段(空 → ErrActorRequired)
SessionID会话 ID
AgentIDAgent ID
Messages消息列表
Model模型(空 → ErrModelRequired)
CycleDetectOverrideper-Run 循环检测覆盖

25 个 Handle 访问器

cell.Agents()          // Agent 管理
cell.Memory()          // 记忆存储
cell.Sessions()        // 会话管理
cell.Knowledge()       // 知识库
cell.Skills()          // 技能管理
cell.Tools()           // 工具注册
cell.HITL()            // 人机交互
cell.Learn()           // 学习系统
cell.Channels()        // IM 渠道
cell.Email()           // 邮件
cell.MCPs()            // MCP Server
cell.Cron()            // 定时任务
cell.HeadlessBrowser() // 无头浏览器
cell.Playwright()      // 用户浏览器自动化
cell.Desktop()         // 桌面自动化
cell.Policy()          // 治理策略
cell.Quotas()          // 配额
cell.Tokens()          // Token 管理
cell.Observe()         // 观测
cell.Providers()       // Provider
cell.Config()          // 配置
cell.TaskMemory()      // 任务记忆
cell.Events()          // 事件流
cell.Workspace()       // 工作区文件

Runtime HTTP 端点

POST /cells/{id}/run                     SSE 流式 Run
POST /cells/{id}/chat                    同步 Chat
GET  /cells/{id}/runs/{runID}/events     SSE Replay

Session HTTP 端点

GET    /cells/{id}/sessions                         会话列表
GET    /cells/{id}/sessions/{sid}/messages           消息列表
DELETE /cells/{id}/sessions/{sid}                    删除会话
PATCH  /cells/{id}/sessions/{sid}                    更新元数据
POST   /cells/{id}/sessions/{sid}/interrupt          中断当前 Run
POST   /cells/{id}/sessions/mark-interrupted         批量标记中断
POST   /cells/{id}/sessions/interrupt-all            中断所有 Run
DELETE /cells/{id}/sessions/delete-by-prefix          按前缀批删

Checkpoint / Branch

GET    /cells/{id}/sessions/{sid}/checkpoints              快照列表
POST   /cells/{id}/sessions/{sid}/checkpoints              创建快照
POST   /cells/{id}/sessions/{sid}/checkpoints/{cpid}/restore  回滚
POST   /cells/{id}/sessions/{sid}/checkpoints/{cpid}/fork     分支
DELETE /cells/{id}/sessions/{sid}/checkpoints/{cpid}       删除
GET    /cells/{id}/sessions/{sid}/branches                 分支列表
DELETE /cells/{id}/sessions/{sid}/branches/{bid}           删除分支

基础设施端点

GET /health     健康检查(无 auth)
GET /metrics    Prometheus 指标

Gateway 中间件链

请求通过以下中间件链处理:

path parse → cell exist → auth → state → quota → dispatch