selectToolDesc returns the custom description if provided, otherwise selects the appropriate i18n description based on the current language setting.

selectToolName returns the custom tool name if provided, otherwise returns the default name.

wrapIterWithCancelCtx wraps an iterator with cancel lifecycle management. It calls markDone when the inner iterator is fully drained, ensuring the can

AddInputWithOptions creates a dependency between nodes with custom configuration options. It allows fine-grained control over both data flow and execu

AddLambda adds a Lambda node to the branch. eg. lambdaFunc := func(ctx context.Context, in string, opts ...any) (out string, err error) { // logic

AgentWithDeterministicTransferTo wraps an agent to transfer to given agents deterministically. NOT RECOMMENDED: Agent transfer with full context shar

AppendGraph add a AnyGraph node to the chain. AnyGraph can be a chain or a graph. e.g. graph := compose.NewGraph[string, string]() chain.AppendGrap

ConcatItems the caller should ensure len(items) > 1

DesignateNode sets the key of the node to which the option will be applied. notice: only effective at the top graph. e.g. embeddingOption := compose.

GetComposeOptions returns all compose options from the given agent options.

InferTool creates an [tool.InvokableTool] by inferring the parameter JSON schema from the fields and tags of the input type T. The tool automatically

New creates a supervisor-based multi-agent system with the given configuration. In the supervisor pattern, a designated supervisor agent coordinates

ParseTypeName returns the name of the type of the given value. It takes a reflect.Value as input and processes it to determine the underlying type. If

WithNoDirectDependency creates a data mapping without establishing a direct execution dependency. The predecessor node will still complete before the

WithToolOption adds tool options to the ToolsNode.

copyTypedAgentEvent copies a TypedAgentEvent. If the MessageVariant is streaming, the MessageStream will be copied. RunPath will be deep copied. The r

getCancelContext retrieves the cancelContext from the Go context, or nil.

toolResultToBlocks converts a ToolResult's multimodal parts into FunctionToolResultBlocks. This preserves all media types (text, image, audio, video,

AddGraph adds a graph node to the parallel. It is useful when you want to use a graph or a chain as a node in the parallel. eg. graph, err := compos

DesignateNodeWithPath sets the path of the node(s) to which the option will be applied. You can specify a node in the subgraph through `NodePath` to m

EnsureMessageID assigns a UUID v4 if no message ID is present. Idempotent: if ID already set, no-op. Returns the (possibly newly created) Extra map.

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

GetRunLocalValue retrieves a value that was set during the current agent Run() invocation. The value is scoped to this specific execution and is not s

Interrupt pauses tool execution and signals the orchestration layer to checkpoint. The tool can be resumed later with optional data. Parameters: - ct

NewFinalizer creates a new FinalizerBuilder that builds a FinalizeFunc by chaining handlers.

Send puts an item into the channel

SignalToPersistenceMaps flattens an InterruptSignal tree into two maps suitable for persistence in a checkpoint.

WithLambdaCallbackEnable enables the callback aspect of the lambda function.

WithOnEOF registers a callback that fires once when the stream reaches EOF. The callback can inject an error or a value before the final io.EOF is ret

WithPushStrategy provides dynamic push option resolution based on the current turn state. The callback receives the current turn's context and TurnCon

WrapEnhancedInvokableToolCall wraps an enhanced tool's synchronous execution with custom behavior. Return the input endpoint unchanged and nil error i

collectEvents drains all events from the iterator (non-streaming).

getToolCallsGeneric extracts tool call info from an assistant message.

makeStreamingEventWrapper creates an agentEventWrapper with a streaming MessageOutput whose stream yields the given message then terminates with strea

newMockAgent creates a new mock agent with the given name, description, and responses

normalizePath normalizes a file path by ensuring it starts with "/" and removing trailing slashes.

snakeToCamel converts a snake_case string to CamelCase.

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

GetImplSpecificOptions provides tool author the ability to extract their own custom options from the unified Option type. T: the type of the impl spec

GetSourceName extracts the source stream name from a SourceEOF error. It returns the source name and a boolean indicating whether the error was a Sour

New creates a new Deep agent instance with the provided configuration. This function initializes built-in tools, creates a task tool for subagent orch

NewEventSenderToolWrapper returns a ChatModelAgentMiddleware that sends tool result events. By default, the framework places this before all user midd

SetRunLocalValue sets a key-value pair that persists for the duration of the current agent Run() invocation. The value is scoped to this specific exec

StreamableLambda creates a Lambda with streamable lambda function without options.

String converts an Address into its unique string representation.

SystemAgenticMessage represents a message with AgenticRoleType "system".

WithLayerPayload creates an option to attach layer-specific metadata to the interrupt's state.

WithPreemptTimeout is like WithPreempt but adds a timeout. If the agent has not reached the safe point within timeout, the preemption escalates to imm

WithToolAliases sets the tool aliases for the ToolsNode call option. When used with WithToolList, it overrides the global alias configuration for the