AddAgenticChatTemplate adds a prompt.AgenticChatTemplate node to the branch. eg. chatTemplate, err := prompt.FromAgenticMessages(schema.FString, &sc

AddAgenticChatTemplateNode adds an agentic chat template node and returns it.

AddAgenticChatTemplateNode add node that implements prompt.AgenticChatTemplate. e.g. chatTemplate, err := prompt.FromAgenticMessages(schema.FString,

AddAgenticModel adds a agentic.Model to the parallel. eg. model1, err := openai.NewAgenticModel(ctx, &openai.AgenticModelConfig{ Model: "gpt-4o",

AddAgenticModel adds a agentic.Model node to the branch. eg. model1, err := openai.NewAgenticModel(ctx, &openai.AgenticModelConfig{ Model: "gpt-4o

AddAgenticModelNode add node that implements agentic.Model. e.g. model, err := openai.NewAgenticModel(ctx, &openai.AgenticModelConfig{ Model: "gpt

AddAgenticToolsNode adds a node that implements AgenticToolsNode. e.g. toolsNode, err := compose.NewAgenticToolsNode(ctx, &compose.ToolsNodeConfig{}

AddAgenticToolsNode adds a tools node to the parallel. eg. toolsNode, err := compose.NewAgenticToolsNode(ctx, &compose.ToolsNodeConfig{ Tools: []t

AddAgenticToolsNode adds a AgenticToolsNode to the branch. eg. toolsNode, err := compose.NewAgenticToolsNode(ctx, &compose.ToolsNodeConfig{ Tools:

AddBranch adds a branch to the graph. e.g. condition := func(ctx context.Context, in string) (string, error) { return "next_node_key", nil } end

AddChatModel adds a ChatModel node to the branch. eg. chatModel01, err := openai.NewChatModel(ctx, &openai.ChatModelConfig{ Model: "gpt-4o", })

AddChatModelNode add node that implements model.BaseChatModel. e.g. chatModel, err := openai.NewChatModel(ctx, &openai.ChatModelConfig{ Model: "gp

AddChatTemplate adds a ChatTemplate node to the branch. eg. chatTemplate, err := prompt.FromMessages(schema.FString, &schema.Message{ Role: sch

AddChatTemplateNode add node that implements prompt.ChatTemplate. e.g. chatTemplate, err := prompt.FromMessages(schema.FString, &schema.Message{ R

AddDocumentTransformer adds an Document Transformer node to the branch. eg. markdownSplitter, err := markdown.NewHeaderSplitter(ctx, &markdown.Heade

AddDocumentTransformerNode adds a document transformer node and returns it.

AddDocumentTransformerNode adds a node that implements document.Transformer. e.g. markdownSplitter, err := markdown.NewHeaderSplitter(ctx, &markdown

AddEmbedding adds an Embedding node to the branch. eg. embeddingNode, err := openai.NewEmbedder(ctx, &openai.EmbeddingConfig{ Model: "text-embeddi

AddEmbeddingNode adds a node that implements embedding.Embedder. e.g. embeddingNode, err := openai.NewEmbedder(ctx, &openai.EmbeddingConfig{ Model

AddEnd connects a node to END with optional field mappings. Deprecated: use *Workflow[I,O].End() to obtain a WorkflowNode instance for END, then work

AddGraph adds a generic Graph node to the branch. eg. graph, err := compose.NewGraph[string, string]() cb.AddGraph("graph_node_key", graph)

AddGraphNode add one kind of Graph[I, O]、Chain[I, O]、StateChain[I, O, S] as a node. for Graph[I, O], comes from NewGraph[I, O]() for Chain[I, O], come

AddIndexer adds an Indexer node to the branch. eg. indexer, err := volc_vikingdb.NewIndexer(ctx, &volc_vikingdb.IndexerConfig{ Collection: "my_col

AddIndexerNode adds a node that implements indexer.Indexer. e.g. indexer, err := vikingdb.NewIndexer(ctx, &vikingdb.IndexerConfig{}) graph.AddInde

AddLambdaNode add node that implements at least one of Invoke[I, O], Stream[I, O], Collect[I, O], Transform[I, O]. due to the lack of supporting metho

AddLoader adds a Loader node to the branch. eg. pdfParser, err := pdf.NewPDFParser() loader, err := file.NewFileLoader(ctx, &file.FileLoaderConfig{

AddLoaderNode adds a document loader node to the workflow and returns it.

AddLoaderNode adds a node that implements document.Loader. e.g. loader, err := file.NewLoader(ctx, &file.LoaderConfig{}) graph.AddLoaderNode("load

AddPassthrough adds a Passthrough node to the branch. eg. cb.AddPassthrough("passthrough_node_key")

AddPassthroughNode adds a passthrough node to the graph. mostly used in pregel mode of graph. e.g. graph.AddPassthroughNode("passthrough_node_key")

AddRetriever adds a Retriever node to the branch. eg. retriever, err := volc_vikingdb.NewRetriever(ctx, &volc_vikingdb.RetrieverConfig{ Collection

AddRetrieverNode adds a retriever node and returns it.

AddRetrieverNode adds a node that implements retriever.Retriever. e.g. retriever, err := vikingdb.NewRetriever(ctx, &vikingdb.RetrieverConfig{}) g

AddToolsNode adds a node that implements ToolsNode. e.g. toolsNode, err := compose.NewToolNode(ctx, &compose.ToolsNodeConfig{}) graph.AddToolsNode

AddToolsNode adds a ToolsNode to the branch. eg. toolsNode, err := compose.NewToolNode(ctx, &compose.ToolsNodeConfig{ Tools: []tools.BaseTool{...}

AgentWithOptions wraps an agent with flow-specific options and returns it. NOT RECOMMENDED: Agent transfer with full context sharing between agents h

AppendAgenticChatTemplate add a prompt.AgenticChatTemplate node to the chain. eg. chatTemplate, err := prompt.FromAgenticMessages(schema.FString, &s

AppendAgenticToolsNode add a AgenticToolsNode node to the chain. e.g. toolsNode, err := compose.NewAgenticToolsNode(ctx, &compose.ToolsNodeConfig{

AppendDocumentTransformer add a DocumentTransformer node to the chain. e.g. markdownSplitter, err := markdown.NewHeaderSplitter(ctx, &markdown.Heade

BeforeModelRewriteState injects Agents.md content as a User message before the first User message in the conversation. The injected message is tagged

BindTools mocks base method.

BindTools indicates an expected call of BindTools.

ClearRunCtx clears the run context of the multi-agents. This is particularly useful when a customized agent with a multi-agents inside it is set as a

Close marks the channel as closed

Close notify the receiver that the stream sender has finished. The stream receiver will get an error of io.EOF from StreamReader.Recv(). Notice: alway

Collect works like `stream input => pong`.

Compile builds the workflow into a runnable graph.

Compile take the raw graph and compile it into a form ready to be run. e.g. graph, err := compose.NewGraph[string, string]() if err != nil {...}