AddGraphNode adds a nested graph node to the workflow and returns it.

WithStatePreHandler modify node's input of I according to state S and input or store input information into state, and it's thread-safe. notice: this

markDone marks the execution as finished through any non-cancel path (normal completion, business interrupt, or error). This is safe to call even if a

NewSequentialAgent creates an agent that runs sub-agents sequentially. NOT RECOMMENDED: Workflow agents are built on agent transfer with full context

withCancelContext stores a cancelContext in the Go context.

Build constructs the final TypedFinalizeFunc by chaining all registered handlers and post-processing the summary message as DefaultFinalize does. For

GetMessageID returns the eino-internal message ID from the given message, or "".

EventFromMessage creates an AgentEvent containing the given message and optional stream. role identifies the origin of this event: - schema.Assistant

ResumeWithData prepares a context to resume a single, specific component with data. It is the primary function for the "Explicit Targeted Resume" stra

WithGraphName sets a name for the graph. The name is used for debugging and logging purposes. If not set, a default name will be used.

NewAgent creates a ReAct agent that feeds tool response into next round of Chat Model generation. IMPORTANT!! For models that don't output tool calls

shouldCancel returns true if a cancel has been requested (cancelChan is closed).

FromMessages creates a new DefaultChatTemplate from the given templates and format type. eg. template := prompt.FromMessages(schema.FString, &schema

WithLambdaOption is a functional option type for lambda component.

String returns the string representation of the message. e.g. msg := schema.UserMessage("hello world") fmt.Println(msg.String()) // Output will be:

GetSessionValues returns all session key-value pairs for the current run.

NewGraphBranch creates a new graph branch. It is used to determine the next node based on the condition. e.g. condition := func(ctx context.Context,

NewParallel creates a new parallel type. it is useful when you want to run multiple nodes in parallel in a chain.

WithCallbacks adds callback handlers to receive agent lifecycle events. Handlers receive OnStart with AgentCallbackInput and OnEnd with AgentCallbackO

WithRecursive opts into recursive cancel propagation. By default, cancel modes only affect the root agent; descendant agents inside AgentTools are not

New creates an agentsmd middleware that injects Agents.md content into every model call. The content is loaded from the configured file paths via Back

WithNodeTriggerMode sets the trigger mode for nodes in the graph. The trigger mode determines when a node is triggered during graph execution, ref: ht

Ptr returns a pointer to the given value.

AppendParallel add a Parallel structure (multiple concurrent nodes) to the chain. e.g. parallel := compose.NewParallel() parallel.AddChatModel("ope

Build returns a Handler with the functions set in the builder.

MapFields creates a FieldMapping that maps a single predecessor field to a single successor field. Field: either the field of a struct, or the key of

OnEndFn sets the handler for the end timing.

OnStart Fast inject callback input / output aspect for component developer e.g. func (t *testChatModel) Generate(ctx context.Context, input []*schem

invokeTool is a helper to invoke a tool with JSON input

NewPanicErr creates a new panic error. panicErr is a wrapper of panic info and stack trace. it implements the error interface, can print error message

ToFieldPath creates a FieldMapping that maps the entire predecessor output to a single successor field path. Example: // Maps the entire predecesso

concatContentBlockHelper is a generic helper function that reduces code duplication for concatenating content blocks of a specific type.

AddPassthroughNode adds a passthrough node to the workflow and returns it.

AppendBranch add a conditional branch to chain. Each branch within the ChainBranch can be an AnyGraph. All branches should either lead to END, or conv

Handler returns the callbacks.Handler created by HandlerHelper.

WithNodeKey set the node key, which is used to identify the node in the chain. only for use in Chain/StateChain.

deriveAgentToolCancelContext creates the cancelContext used by an AgentTool's internal agent. It receives recursive cancel propagation from the parent

============================================================================= preemptController unit tests ===========================================

setRecursive(false) is a no-op; recursive is monotonically escalating: once set to true, it cannot be reverted.

ConcatMessageStream drains a stream of messages and returns a single concatenated message representing the merged content.

ConcatToolResults merges multiple ToolResult chunks into a single ToolResult. It collects all ToolOutputParts from the input chunks and merges contigu

LsInfo lists file information under the given path.

UntilIdleFor defers the stop until the TurnLoop has been continuously idle (blocked between turns with no pending items) for at least the given durati

WithMaxRunSteps sets the maximum number of steps that a graph can run. This is useful to prevent infinite loops in graphs with cycles. If the number o

reportError. save the first error in the chain.

EXPECT returns an object that allows the caller to indicate expected use.

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

GetCommonOptions extracts standard [Options] from an Option list, merging them onto base. If base is nil, a zero-value Options is used. Implementors

Interrupt creates a basic interrupt action. This is used when an agent needs to pause its execution to request external input or intervention, but doe

ReuseHandlers creates a new context that inherits all handlers already present in ctx and sets a new RunInfo. Global handlers are added if ctx carries