SetMessageID sets the message ID in Extra and returns the resulting map. Copy-on-write: the input map is never mutated, because a message's Extra can

WithAgentCancelTimeout sets a timeout for the cancel operation. This only applies to safe-point modes (CancelAfterChatModel, CancelAfterToolCalls): if

WithGraphInterrupt creates a context with graph cancellation support. When the returned context is used to invoke a graph or workflow, calling the int

WithToolList sets the tool list for the ToolsNode.

addNode. add a node to the chain.

AddSessionValues sets multiple session key-value pairs for the current run.

AddToolsNode adds a tools node and returns it.

GetMessageID returns the message ID from Extra, or "" if not set. Works with any map[string]any (Message.Extra or AgenticMessage.Extra).

NewBackendFromFilesystem creates a new Backend implementation that reads skills from a filesystem. It searches for SKILL.md files in immediate subdire

NewMiddleware creates a new skill middleware handler for ChatModelAgent. The handler provides a skill tool that allows agents to load and execute ski

Send sends a value to the stream. e.g. closed := sw.Send(i, nil) if closed { // the stream is closed }

WithInputKey sets the input key of the node. this will change the input value of the node, for example, if the pre node's output is map[string]any{"ke

the caller should ensure len(vs) > 1

FromField creates a FieldMapping that maps a single predecessor field to the entire successor input. This is an exclusive mapping - once set, no other

GetSessionValue retrieves a session value by key and reports whether it exists.

New constructs and returns the tool search middleware. The tool search middleware enables dynamic tool selection for agents with large tool libraries

NewHandlerHelper creates a new component template handler builder. This builder can be used to configure and build a component template handler, which

NewLoopAgent creates an agent that loops over sub-agents with a max iteration limit. NOT RECOMMENDED: Workflow agents are built on agent transfer wit

SetSubAgents sets sub-agents for the given agent and returns the updated agent. NOT RECOMMENDED: Agent transfer with full context sharing between age

ToJSONSchema parses ParamsOneOf, converts the parameter description that user actually provides, into the format ready to be passed to Model.

WithMessageFuture returns an agent option and a MessageFuture interface instance. The option configures the agent to collect messages generated during

WithToolsNodeOption is a functional option type for tools node component.

WrapImplSpecificOptFn is the option to wrap the implementation specific option function.

AddChatModelNode adds a chat model node and returns it.

OnEnd invokes the OnEnd timing for all registered handlers. Call this after the component produces a successful result. Handlers run in registration o

OnError invokes the OnError timing for all registered handlers. Call this when the component returns an error. Errors that occur mid-stream (after the

StatefulInterrupt pauses tool execution with state preservation. Use this when the tool has internal state that must be restored on resume. Parameter

WithGraphInterruptTimeout specifies the max waiting time before generating an interrupt. After the max waiting time, the graph will force an interrupt

WithStatePostHandler modify node's output of O according to state S and output or store output information into state, and it's thread-safe. notice: t

-- Tests for CancelImmediate in nested agent structures --

AddSessionValue sets a single session key-value pair for the current run.

ConvAgentCallbackOutput converts a generic CallbackOutput to AgentCallbackOutput. Returns nil if the output is not an AgentCallbackOutput.

Edit replaces string occurrences in a file.

GlobInfo returns file info entries matching the glob pattern.

NewNodePath specifies a path to a node in the graph, which is composed of node keys. Starting from the top graph, following this set of node keys can

WithChatModelOption is a functional option type for chat model component. e.g. chatModelOption := compose.WithChatModelOption(model.WithTemperature(

WithComposeOptions returns an agent option that specifies compose options.

WrapImplSpecificOptFn wraps the impl specific option functions into Option type. T: the type of the impl specific options struct. Tool implementations

consumeStream drains the message stream, setting concatenatedMessage on success or StreamErr on failure. The stream is always replaced with an error-f

filterCancelOption removes any AgentRunOption that sets a cancelCtx on *options. This prevents inner (nested) agents from receiving the cancel option

valueOrDefault returns the value pointed to by ptr, or defaultValue if ptr is nil.

Clone returns a shallow copy of map. If the given map is nil, nil is returned. 🚀 EXAMPLE: Clone(map[int]int{1: 1, 2: 2}) ⏩ map[int]int{1: 1, 2: 2}

Generate generates a response from the agent.

GetMessages returns an iterator for retrieving messages generated during "agent.Generate" calls.

GetToolCallID gets the current tool call id from the context.

InitCallbacks creates a new context with the given RunInfo and handlers, completely replacing any RunInfo and handlers already in ctx. Use this when

InvokableLambdaWithOption creates a Lambda with invokable lambda function and options.

New constructs and returns the filesystem middleware as a ChatModelAgentMiddleware. This is the recommended constructor for new code. It returns a Ch

NewChainBranch creates a new ChainBranch instance based on a given condition. It takes a generic type T and a GraphBranchCondition function for that t

NewParallelAgent creates an agent that runs sub-agents in parallel. NOT RECOMMENDED: Workflow agents are built on agent transfer with full context sh

SetStaticValue sets a static value for a field path that will be available during workflow execution. These values are determined at compile time and

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

ToInterruptContexts converts the internal InterruptSignal tree into a list of user-facing InterruptCtx objects for the root causes of the interruption

WithGraphCompileOptions when the node is an AnyGraph, use this option to set compile option for the node. e.g. graph.AddNode("node_name", node, comp