Documentation
¶
Overview ¶
Package steering 运行中转向队列:turn 执行中用户插入的新输入按投递语义 分流——guide(下一个模型请求边界前注入,不打断当前工具执行)与 queue (本 turn 结束后作为下一轮输入)。对标 ZCode steering.ts 的 pendingInputs 形态;不含 turn 机集成(那是运行时的事),只提供线程安全的队列原语。
关键语义(ZCode 踩坑固化的):
- guide 输入不丢:模型执行窗口已关闭时(Drain 后未消费)fallback 为 queue 语义,由调用方在 turn 末尾统一取走;
- 同一 turn 内 guide 注入后续跑而非新开 turn,保持上下文连续。
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue 待投递输入队列(并发安全)。零值可用。
func (*Queue) DemoteGuidesToQueued ¶
func (q *Queue) DemoteGuidesToQueued()
DemoteGuidesToQueued 把全部 guide 降级为 queued(turn 提前收尾/执行窗口 关闭时调用——guide 不丢,转排队)。
func (*Queue) DequeueQueued ¶
DequeueQueued 取一条 queued 输入(FIFO)。队列空返回 ok=false。
func (*Queue) DrainGuides ¶
DrainGuides 取走全部 guide 输入(模型请求边界调用)。模型执行窗口关闭时 guide 降级为 queued——不丢输入。
Click to show internal directories.
Click to hide internal directories.