Expand description
Messages:框架对外的实时消息通道。
它是推给前端实时渲染的内容流,承载流式增量(Partial*)与成型消息。
观测/监控则走标准 tracing span/event,由宿主程序决定是否导出到 OpenTelemetry。
故意做成一个具体 struct(MessageChannel)而非 trait —— 内部就是一个 mpsc,
使用方拿 receiver 消费即可,不需要实现任何 sink。未配置时用 MessageChannel::disconnected,
send 静默丢弃。
Structs§
- Agent
Message - 一条对前端的消息:会话 id + 发生时间 + 具体内容。
- Message
Channel - 实时消息通道。
Clone即克隆底层 sender,可多生产者并发推送。
Enums§
- Message
Kind - 消息内容。
Partial*是流式增量,与之配对的成型变体在内容完整时发出。