AssistantDeltaText returns assistant text from one streaming chunk. It intentionally delegates to AssistantText because schema.Message and AgenticMess

AssistantText returns generated assistant text from a message.

DecodeMessages deserializes messages previously encoded by EncodeMessages.

Gob registrations for eino message types are provided by the framework; no manual registration needed here. EncodeMessages serializes messages using G

ExportGraph exports the underlying graph from Agent, along with the []compose.GraphAddNodeOpt to be used when adding this graph to another graph.

Middleware constructs and returns a compose.ToolMiddleware. This middleware is designed to catch errors from tool executions and replace them with a c

Truncate shortens long strings for console output. JSON strings are compacted first so tool results remain readable in narrow terminals.

WithCtxLogger sets a context-aware logger for request/response/chunk logs.

WithLogger sets a simple printf-style logger.

WithMaskHeaders masks specified header names (case-insensitive) in logs.

WithPrintAuth controls whether the Authorization header value is printed.

formatToolCall formats a function tool call for display in a chip.

makeGenResume returns the GenResume callback for interrupt/resume.

repair attempts minimal work first (validity check, region isolation) and only uses jsonrepair when necessary. It trims common LLM artifacts.

Run the server

startLoopCleanup spawns a goroutine that waits for the loop to exit (e.g. due to an error or all items consumed) and nils out ts.loop so the next hand

Builder 初始化全部子图并连接

DrainToolResult consumes a tool-result variant and returns its text and call ID.

get messages with max window size

GetMsgIdx returns the stored component slot counter.

GetPendingInterruptID returns the stored interrupt ID, or "" if none is pending.

HasContent reports whether a message carries any content worth persisting.

InitAPMPlusTracing initializes APMPlus observability components for Eino applications Creates Eino APMPlus callbacks and optionally initializes Hertz

IsCallbacksEnabled 透出内部的 ChatModel 是否已埋入了回调切面.

List returns metadata for all known sessions.

LogMiddleware 记录 HTTP 请求日志

Middleware bundles both invokable and streamable wrappers for convenience.

Read returns decoded messages for the given session; returns nil if absent.

RenderHistory writes the beginRendering + history surfaceUpdate messages to w without running an agent. Used to populate the chat window when a sessio

RoleLabel returns the human label used by chatwitheino UIs.

SetMsgIdx stores the A2UI component slot counter so a resume can continue from it.

Stream 以流式的方式调用多智能体.