StreamContinue resumes an interrupted stream without resetting the client UI. It continues from startMsgIdx, appending new chips to the existing compo

VariantIsToolResult reports whether a message variant carries tool output.

VariantRoleLabel returns a display label without consuming a stream.

WithMaxStreamLogBytes caps stream summary size when using a plain Logger.

WithStreamLogging enables logging for streaming responses (SSE/NDJSON).

drainEvents consumes all events from the iterator, printing output and detecting CancelError. Returns true if a CancelError was encountered. Events ar

makeGenInput returns the GenInput callback. It builds agent messages from session history + workspace context.

makeOnAgentEvents returns the OnAgentEvents callback — the bridge between the TurnLoop and the HTTP handler.

makePrepareAgent returns the PrepareAgent callback — returns the same agent.

newBatchBridgeStore creates a new empty checkpoint store.

parseBatchIndex extracts the batch index from a checkpoint ID. Returns error if the ID format is invalid.

removeErrorHandler is an error handler function that generates a string describing the error that occurred during a tool call.

streamEvents is the shared event-processing loop used by StreamToWriter and StreamContinue. Returns: last assistant text content, intermediate message

BindRoutes 注册路由

ConcatChunks merges streaming message chunks using the official Eino schema helpers. For AgenticMessage this preserves reasoning blocks and reasoning

Delete removes the session file and evicts it from the cache.

Encode serializes a Message to JSON followed by a newline byte.

Generate implements model.BaseChatModel. It reads state, calls GetOptionFunc, increments iteration, and delegates to the inner model.

GetAllTravelTools returns all travel-related tools

GetTools initializes and returns a list of tools. It hooks in the toolCallResultHandler to process the results of any tool calls.