聚合根 AR
实体 Entity
值对象 VO
Repository
领域事件 Event
技术方案 · 控制信道 + survive-reattach
每智能体由独立 detached supervisor 托管:worker daemon 重启 / 信道断连,supervisor 不退出,重连后重新附着既有执行(survive-reattach)。控制信道 = 有序可重放日志,worker 主动消费 + ack offset(lastAckedOffset),配合执行层幂等键双层去重;SSE 优先、轮询回退保证最终送达。
文件传输:open→completed · canceled · expired(后三 term)
战术设计 · 聚合 / 实体 / 值对象 / 事件
环境 · Environment environment + workforce + files + blobstore
这是 4 个包的文档合并:丰富的 Worker 字段在
workforce,瘦控制信道 AR 在 environment,文件在 files,blob 在 blobstore。Worker(规范/丰富 AR)AR · workforce
id · name · status · capabilities[]Capability · concurrency · discovery · lastHeartbeatAt · workingSeconds · enrolledAt · onlineAt · offlineAt · offlineReason · offlineMessage · organizationID · version
WorkerRepository · FindByID · ListByOrg · Save · Update
Worker(控制信道 AR)AR · environment
id · name · status(offline⇄online) · lastAckedOffset · lastHeartbeatAt · createdAt · updatedAt · version
瘦 AR,不存 org;承载 offset ack + 心跳。
AgentInstance · BootstrapToken AR · workforce
智能体实例 + 入网引导令牌
AgentInstanceRepository · BootstrapTokenRepository
workforce.worker.enrolledworkforce.worker.onlineworkforce.worker.offlineworkforce.worker.bootstrap_token.issuedworkforce.agent_instance.created
FileTransferSession 传输会话 AR · files
id · fileURI(FileURI) · transferURI(ac://transfers/{id}) · direction(TransferDirection) · status · contentType · size · sha256 · scope(FileScope) · scopeID · createdBy · createdAt · expiresAt
状态机:
open→
completed · canceled · expired
(后三 term)
值对象 / 实体
FileURI(ac://files/{ulid})FileReferenceRepository
FileTransferSessionRepository · FileReferenceRepository
BlobStore 对象存储 通用基础设施 · blobstore
LocalDir 内容寻址(sha256)· 引用计数 GC(files/service/gc.go:ref_count=0 + 宽限 → 回收)。
领域服务 · 控制信道:worker 主动消费有序可重放日志(offset ack)+ 执行层幂等键双层去重;SSE 优先、轮询回退。文件传输:建会话即铸 fileURI → 完成进 GC 宽限 → 下载先校验可达性。
跨域协作:本域向智能体提供 Worker 状态以派生 Agent 可用性(D,环境优先);以 ACL(agentadapter)隔离外部 Agent CLI 协议;files→blobstore 内部供应。完整业务流见 战略设计 · Event Storming。