remapArgs replaces alias keys in the JSON arguments string with canonical keys. aliasMap: alias → canonical mapping

setGraphInterruptFunc appends a graph interrupt function to the list. If an immediate cancel was already requested, fires it retroactively. Multiple f

AddDependency creates an execution-only dependency between nodes. The current node will wait for the predecessor node to complete before executing, bu

AppendAddressSegment creates a new execution context for a sub-component (e.g., a graph node or a tool call). It extends the current context's addres

AppendAddressSegment creates a new execution context for a sub-component (e.g., a graph node or a tool call). It extends the current context's addres

AppendChatModel add a ChatModel node to the chain. e.g. model, err := openai.NewChatModel(ctx, config) if err != nil {...} chain.AppendChatModel(m

CollectableLambda creates a Lambda with collectable lambda function without options.

CompositeInterrupt creates an interrupt that aggregates multiple sub-interrupts. Use this when a tool internally executes a graph or other interruptib

ConcatReasoningExtensions concatenates multiple ReasoningExtension chunks into a single one.

FromInterruptContexts converts a list of user-facing InterruptCtx objects into an internal InterruptSignal tree. It correctly handles common ancestors

Interrupt creates a special error that signals the execution engine to interrupt the current run at the component's specific address and save a checkp

New creates a new plan-execute-replan agent with the given configuration. The plan-execute-replan pattern works in three phases: 1. Planning: Generate

NewExecutor creates a new executor agent.

Receive gets an item from the channel (blocks if empty). Returns (value, true) if an item was received. Returns (zero, false) if the channel was close

Register registers a type for serialization. This is required for any type you intend to persist in a graph or ADK checkpoint. It automatically determ

Stream calls the agent and returns a stream response.

ToMessageInputParts converts ToolOutputPart slice to MessageInputPart slice. This is used when passing tool results as input to the model. Parameters

TransformableLambda creates a Lambda with transformable lambda function without options.

TypeOf returns the type of T. eg. TypeOf[int] returns reflect.TypeOf(int). eg. TypeOf[*int] returns reflect.TypeOf(*int).

WithAgentCallbacks registers callbacks to be invoked by the host multi-agent.

WithLambdaType sets the type of the lambda function.

WithTools is the option to set tools for the model.

WrapEnhancedStreamableToolCall wraps an enhanced tool's streaming execution with custom behavior. Return the input endpoint unchanged and nil error if

WrapInvokableToolCall wraps a tool's synchronous execution with custom behavior. Return the input endpoint unchanged and nil error if no wrapping is n

buildCancelFunc builds the AgentCancelFunc for external use.

defaultTruncHandler applies the same truncation strategy to both non-streaming and streaming tool outputs. Processing steps: 1. Read and join tool ou

formatMediaString formats URL, Base64Data, MIMEType and Detail for media content

newFuncToolResultContentBlock creates a FunctionToolResultContentBlock from a typed content pointer.

set automatic close for event's message stream

AddChatTemplateNode adds a chat template node and returns it.

AppendAddressSegment adds an address segment for the current execution context.

BatchResumeWithData is the core function for preparing a resume context. It injects a map of resume targets and their corresponding data into the cont

BeforeAgent is called before each agent run, allowing modification of the agent's instruction and tools configuration.

BindTools bind tools to the model. BindTools before requesting ChatModel generally. notice the non-atomic problem of BindTools and Generate.

CompositeInterrupt creates a special error that signals a composite interruption. It is designed for "composite" nodes (like ToolsNode) that manage mu

Concat returns the unions of maps as a new map. 💡 NOTE: - Once the key conflicts, the newer value always replace the older one ([DiscardOld]), - If

ConcatAssistantGenTextExtensions concatenates multiple AssistantGenTextExtension chunks into a single one.

ConcatMessageArray merges aligned slices of messages into a single slice, concatenating messages at the same index across the input arrays.

ConvCallbackOutput converts the callback output to the tool callback output.

GetNextResumptionPoints finds the immediate child resumption points for a given parent address.

IsInterruptRerunError reports whether the error represents an interrupt-and-rerun and returns any attached info.

MessagesPlaceholder can render a placeholder to a list of messages in params. e.g. placeholder := MessagesPlaceholder("history", false) params := m

NewPlanner creates a new planner agent based on the provided configuration. The planner agent uses either ChatModelWithFormattedOutput or ToolCallingC

NewStreamGraphBranch creates a new stream graph branch. It is used to determine the next node based on the condition of stream input. e.g. condition

OnErrorFn sets the handler for the error timing.

StatefulInterrupt creates an interrupt action that also saves the agent's internal state. This is used when an agent has internal state that must be r

Store stores the documents and returns their assigned IDs.

WithAfterToolCallsHook registers a per-run hook that fires synchronously after all tool calls in a react iteration complete, before the next ChatModel

WithInterruptAfterNodes instructs to interrupt after the given nodes.

checkGobEncodability probes whether the value can be gob-encoded as part of a map[string]any, which is exactly how State.Extra is serialized during ch

collectAgenticToolEvents filters tool result events from the agentic iterator. Agentic tool results have AgenticRole == AgenticRoleTypeUser and contai