Skip to content

Output Projection

状态

  • idle
  • projecting
  • caught_up
  • rebuilding
  • failed

基本流程

  1. 输出事件进入 event log
  2. projector 获取 run 级 lease
  3. 读取 projectedSequence 之后的事件批次
  4. 更新 message / artifact / checkpoint 等投影
  5. 推进 projectedSequence
  6. 释放 lease 或保持活跃轮询

规范要求

  • projection MUST 以事件序号推进,不得跳过未知事件
  • projection MUST 支持从头重建
  • lease 丢失时,当前 projector MUST 停止继续提交写入
  • SSE replay MUST 基于 event log,而不是消息表

side effect

  • webhook、artifact materialization、message completed 通知都属于 side effect
  • side effect SHOULD 依赖已确认的投影推进点
  • 重放时 MUST 有能力禁用重复 side effect 或基于幂等键抑制重复

Generated from spec source.