isAssistantMsg checks if a message has assistant role.

isImmediateCancelled returns true if an immediate graph interrupt has been fired (CancelImmediate or timeout escalation). This is stronger than should

markCancelHandled signals that the cancel path in the runFunc has created and sent a CancelError. Transitions state to stateCancelHandled so that: 1.

mergeToolConfigWithDesc merges ToolConfig with legacy Desc field Priority: ToolConfig.Desc > legacy Desc Returns an empty ToolConfig if both are nil (

-- Tests for cancel support across all agent types -- cancelTestAgent is a ChatModelAgent-based agent where the model blocks until signalled, allowing

AddChatTemplate adds a chat template to the parallel. eg. chatTemplate01, err := prompt.FromMessages(schema.FString, &schema.Message{ Role: sch

AppendChatTemplate add a ChatTemplate node to the chain. eg. chatTemplate, err := prompt.FromMessages(schema.FString, &schema.Message{ Role: sc

AppendGlobalHandlers appends handlers to the process-wide list of callback handlers. Global handlers run before per-invocation handlers provided via c

ChatModel sets the chat model handler for the handler helper, which will be called when the chat model component is executed.

CompositeInterrupt creates an interrupt event that aggregates sub-interrupt signals.

ConvAgentCallbackInput converts a generic CallbackInput to AgentCallbackInput. Returns nil if the input is not an AgentCallbackInput.

ConvAgenticCallbackOutput converts the callback output to the agentic model callback output.

ConvCallbackInput converts the callback input to the prompt callback input.

ConvCallbackInput converts the callback input to the tool callback input.

ConvCallbackOutput converts the callback output to the model callback output.

EnsureMessageID assigns a UUID v4 message ID if the message doesn't have one. Idempotent: if ID already set, no-op. Middleware authors should call thi

EventFromAgenticMessage creates a TypedAgentEvent for the AgenticMessage path. Unlike EventFromMessage, it does not require role or toolName parameter

GetMessageStreams returns an iterator for retrieving streaming messages generated during "agent.Stream" calls.

MigrateCheckpointState is an advanced compatibility utility for checkpoint upgrades. It decodes checkpoint bytes using the given serializer, applies

New creates a new plantask middleware that provides task management tools for agents. It adds TaskCreate, TaskGet, TaskUpdate, and TaskList tools to t

NewGraphMultiBranch creates a branch for graphs where a condition selects multiple end nodes; only keys present in endNodes are allowed.

NewMiddleware constructs and returns the filesystem middleware. Deprecated: Use New instead. New returns a ChatModelAgentMiddleware which provides be

NewMultiAgent creates a new host multi-agent system. IMPORTANT!! For models that don't output tool calls in the first streaming chunk (e.g. Claude) t

NewReplanner creates a plan-execute-replan agent wired with plan and respond tools. It configures the provided ToolCallingChatModel with the tools and

NewTool creates an [tool.InvokableTool] from an explicit [schema.ToolInfo] and a typed function. Use this when the schema cannot be inferred from stru

NewTyped creates a new generic patch tool calls middleware. The middleware scans the message history before each model invocation and inserts placeho

NewTyped creates a generic summarization middleware that automatically summarizes conversation history when trigger conditions are met. This is the g

NewTyped creates a generic tool reduction middleware from config. This is the generic constructor that supports both *schema.Message and *schema.Agen

NewTypedAgentTool creates a new agent tool that wraps a TypedAgent as a tool.BaseTool.

RegisterStreamChunkConcatFunc registers a function to concat stream chunks. It's required when you want to concat stream chunks of a specific type. fo

Stream runs the multi-agent in streaming mode and returns a message stream.

TypedInterrupt creates a typed interrupt event that pauses execution to request external input. It is the generic counterpart of Interrupt; see Interr

WithErrWrapper wraps non-EOF errors from the underlying stream reader during conversion by StreamReaderWithConvert. Errors returned by the convert fun

WithGracefulTimeout is like WithGraceful but adds a grace period. If the agent has not reached a safe point within gracePeriod, the stop escalates to

WithInterruptBeforeNodes instructs to interrupt before the given nodes.

WrapInterruptAndRerunIfNeeded wraps the deprecated old interrupt errors, with the current execution address. If the error is returned by either Interr

WrapModel wraps a chat model with custom behavior around the actual model call. Return the input model unchanged and nil error if no wrapping is neede

createCancelError creates a CancelError based on the current cancel state.

functionToolResultAgenticMessage constructs a function tool result message with AgenticRoleType "user".

============================================================================ Generic helper functions ================================================