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 |
| AgentID | Agent ID |
| Messages | 消息列表 |
| Model | 模型(空 → ErrModelRequired) |
| CycleDetectOverride | per-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