Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CollapsedThinkText ¶
func CollapsedThinkText(thinks []types.AgentEvent) string
CollapsedThinkText joins prefix think event text with spaces.
func ConsumedEvents ¶
func ConsumedEvents(batch Batch) []types.AgentEvent
ConsumedEvents returns all AgentEvents served for one breakpoint dequeue.
Types ¶
type Batch ¶
type Batch struct {
PrefixThink []types.AgentEvent
Breakpoint types.AgentEvent
}
Batch is the slice consumed for one HTTP serve: leading think events plus one breakpoint.
func DequeueToBreakpoint ¶
func DequeueToBreakpoint(queue *[]types.AgentEvent) (batch Batch, ok bool)
DequeueToBreakpoint pops leading think events and exactly one tool_call or message breakpoint from the front of queue. If the queue holds only think events (no breakpoint), nothing is consumed and ok is false.
Source Files
Click to show internal directories.
Click to hide internal directories.