Module trajectory 

Trajectory:一次 agent 运行过程中产生的只读事件流。

它回答的是“刚刚发生了什么“,区别于 Transcript(喂给模型的消息历史)和 Checkpoint(可恢复的状态快照)。典型消费者:

• examples/websocket:run 在一个 task 里跑,事件经 channel 实时推给客户端;
• 日志 / 回放 / 评测。

运行时在关键节点同步 emit,因此 sink 收到事件的顺序天然等于发生顺序; at(毫秒时间戳)只是附带的排序/展示元数据。

Structs

ChannelSink

基于无界 mpsc 的 sink,为 websocket 场景准备: 一个 task 跑 AgentRunTime::run,另一个 task 从 receiver 拉事件推给客户端。

NoopSink

默认 sink:丢弃所有事件。未配置 trajectory 时使用。

TrajectoryEvent

单条轨迹事件:会话 id + 发生时间 + 具体事件。

Enums

TrajectoryEventKind

事件种类。序列化为 { "type": "user_message", ... },方便前端按 tag 分发。

Traits

TrajectorySink

轨迹事件的下游。实现者负责把事件送到日志 / channel / websocket 等。