sendImmediateInterrupt sends the compose graph interrupt signal via graphInterruptFuncs. Also closes immediateChan (used by cancelMonitoredModel to ab

toolResultFromMsgGeneric extracts tool result from a message as a *schema.ToolResult. For *schema.Message: delegates to existing toolResultFromMessage

updateRunPathOnly creates a new context with an updated RunPath, but does NOT modify the Address. This is used by sequential workflows to accumulate e

Agent sets the agent handler for the handler helper, which will be called when the agent is executed.

AgenticAgent sets the agentic agent callback handler for the handler helper, which will be called when an agentic agent is executed.

AppendRetriever add a Retriever node to the chain. e.g. retriever, err := vectorstore.NewRetriever(ctx, config) if err != nil {...} chain.Appen

ConcatAssistantGenTextExtensions merges multiple AssistantGenTextExtension chunks into one.

ConcatResponseMetaExtensions merges multiple ResponseMetaExtension chunks into one.

ConvAgenticCallbackInput converts the callback input to the agentic model callback input.

ConvCallbackInput converts the callback input to the model callback input.

ConvCallbackInput converts the callback input to the indexer callback input.

ConvCallbackInput converts the callback input to the embedding callback input.

ConvCallbackInput converts the callback input to the retriever callback input.

ConvCallbackOutput converts the callback output to the prompt callback output.

ConvCallbackOutput converts the callback output to the indexer callback output.

ConvCallbackOutput converts the callback output to the embedding callback output.

ConvCallbackOutput converts the callback output to the retriever callback output.

EnsureRunInfo ensures the context carries a [RunInfo] for the given type and component kind. If the context already has a matching RunInfo, it is retu

GetCurrentAddress returns the hierarchical address of the currently executing component. The address is a sequence of segments, each identifying a str

MapFieldPaths creates a FieldMapping that maps a single predecessor field path to a single successor field path. Example: // Maps user.profile.name

MergeNamedStreamReaders merges multiple named StreamReaders into one. Unlike [MergeStreamReaders], when a source stream reaches EOF the merged reader

New creates a new skill middleware. It provides a tool for the agent to use skills. Deprecated: Use NewMiddleware instead. New does not support fork

NewMockChatModel creates a new mock instance.

NewMockIndexer creates a new mock instance.

NewTyped creates a generic skill middleware handler for TypedChatModelAgent. This is the generic constructor that supports both *schema.Message and *

OnEndWithStreamOutput invokes the OnEndWithStreamOutput timing. Use this when the component produces a streaming output (Stream / Transform paradigms)

OnStartWithStreamInputFn sets the callback invoked when a component receives streaming input. The handler receives a [*schema.StreamReader] that is a

Reverse returns a new slice with elements in reversed order.

SendToolGenAction attaches an AgentAction to the next tool event emitted for the current tool execution. Where/when to use: - Invoke within a tool's

SetLanguage sets the language for the ADK built-in prompts. The default language is English if not explicitly set.

ToMap collects elements of slice to map, both map keys and values are produced by mapping function f. 🚀 EXAMPLE: type Foo struct { ID int Nam

TypedGetMessage extracts the message from a TypedAgentEvent, concatenating a stream if present.

Values returns the values of the map m. 🚀 EXAMPLE: m := map[int]string{1: "1", 2: "2", 3: "3", 4: "4"} Values(m) ⏩ []string{"1", "4", "2", "3"} //

WithAgentInputSchema sets a custom input schema for the agent tool.

WithCustomExtractor sets a custom extractor function for the FieldMapping. The extractor function is used to extract a value from the 'source' of the

WithSkipCheckpoint tells the TurnLoop not to persist a checkpoint for this Stop call. Use this when the caller does not intend to resume in the future

WithStateModifier installs a state modifier invoked during checkpoint read/write.

WithStopCause attaches a business-supplied reason string to this Stop call. The cause is surfaced in TurnLoopExitState.StopCause and, after the Stoppe

WithStreamStatePostHandler modify node's streaming output of O according to state S and output or store output information into state, and it's thread

WrapStreamableToolCall wraps a tool's streaming execution with custom behavior. Return the input endpoint unchanged and nil error if no wrapping is ne

assertAgenticEventRoleFields asserts that all AgenticMessage events in the list have zero-valued Role and ToolName fields (which are *schema.Message-o

collectAgenticToolContent extracts text from agentic tool result events.

copyMessagesGeneric deep-copies a slice of messages.

getMessageFromWrappedEvent extracts the message from an AgentEvent. If the stream contains an error chunk, this function returns (nil, err) and sets S

getMsgClearedFlagGeneric checks if a message has the cleared flag set.

isNilMessage checks whether a generic message value is nil. Direct `msg == nil` does not compile for generic pointer types in Go; the canonical workar

isToolResultMsg checks if a message is a tool result message. For *schema.Message: role == Tool. For *schema.AgenticMessage: user-role message with at