compose

Nov 20, 2025

Changes in this version

+ func AppendAddressSegment(ctx context.Context, segType AddressSegmentType, segID string) context.Context

+ func BatchResumeWithData(ctx context.Context, resumeData map[string]any) context.Context

+ func CompositeInterrupt(ctx context.Context, info any, state any, errs ...error) error

+ func GetInterruptState[T any](ctx context.Context) (wasInterrupted bool, hasState bool, state T)

+ func GetResumeContext[T any](ctx context.Context) (isResumeFlow bool, hasData bool, data T)

+ func Interrupt(ctx context.Context, info any) error

+ func Resume(ctx context.Context, interruptIDs ...string) context.Context

+ func ResumeWithData(ctx context.Context, interruptID string, data any) context.Context

+ func StatefulInterrupt(ctx context.Context, info any, state any) error

+ func WrapInterruptAndRerunIfNeeded(ctx context.Context, step AddressSegment, err error) error

+ type Address = core.Address

+ func GetCurrentAddress(ctx context.Context) Address

+ type AddressSegment = core.AddressSegment

+ type AddressSegmentType = core.AddressSegmentType

+ const AddressSegmentNode

+ const AddressSegmentRunnable

+ const AddressSegmentTool

+ type InterruptCtx = core.InterruptCtx

type InterruptInfo

+ InterruptContexts []*InterruptCtx

Nov 12, 2025

Changes in this version

+ type InvokableToolEndpoint func(ctx context.Context, input *ToolInput) (*ToolOutput, error)

+ type InvokableToolMiddleware func(InvokableToolEndpoint) InvokableToolEndpoint

+ type StreamToolOutput struct

+ Result *schema.StreamReader[string]

+ type StreamableToolEndpoint func(ctx context.Context, input *ToolInput) (*StreamToolOutput, error)

+ type StreamableToolMiddleware func(StreamableToolEndpoint) StreamableToolEndpoint

+ type ToolInput struct

+ Arguments string

+ CallID string

+ CallOptions []tool.Option

+ Name string

+ type ToolMiddleware struct

+ Invokable InvokableToolMiddleware

+ Streamable StreamableToolMiddleware

+ type ToolOutput struct

+ Result string

type ToolsNodeConfig

+ ToolCallMiddlewares []ToolMiddleware

Sep 29, 2025

Changes in this version

+ func WithGraphInterrupt(parent context.Context) (ctx context.Context, interrupt func(opts ...GraphInterruptOption))

+ type GraphInterruptOption func(o *graphInterruptOptions)

+ func WithGraphInterruptTimeout(timeout time.Duration) GraphInterruptOption

Jul 25, 2025

Changes in this version

type GraphCompileOption

+ func WithEagerExecutionDisabled() GraphCompileOption

Jul 21, 2025

Changes in this version

type Option

+ func WithWriteToCheckPointID(checkPointID string) Option

Jul 15, 2025

Changes in this version

+ var DAGInvalidLoopErr = errors.New("DAG is invalid, has loop")

Jul 9, 2025

Changes in this version

+ func RegisterInternalType(f func(key string, value any) error) error

type GraphCompileOption

+ func WithSerializer(serializer Serializer) GraphCompileOption

+ type Serializer interface

+ Marshal func(v any) ([]byte, error)

+ Unmarshal func(data []byte, v any) error

Jul 3, 2025

Changes in this version

type FieldMapping

+ func (m *FieldMapping) Equals(o *FieldMapping) bool

+ func (m *FieldMapping) FromNodeKey() string

+ func (m *FieldMapping) FromPath() FieldPath

+ func (m *FieldMapping) ToPath() FieldPath

+ type FieldMappingOption func(*FieldMapping)

+ func WithCustomExtractor(extractor func(input any) (any, error)) FieldMappingOption

Jun 25, 2025

Changes in this version

type Option

+ func WithForceNewRun() Option

Jun 19, 2025

Changes in this version

+ type FanInMergeConfig struct

+ StreamMergeWithSourceEOF bool

type GraphCompileOption

+ func WithFanInMergeConfig(confs map[string]FanInMergeConfig) GraphCompileOption

May 30, 2025

Changes in this version

+ func IsInterruptRerunError(err error) (any, bool)

+ func NewInterruptAndRerunErr(extra any) error

type InterruptInfo

+ RerunNodesExtra map[string]any

+ type ToolsInterruptAndRerunExtra struct

+ ExecutedTools map[string]string

+ RerunExtraMap map[string]any

+ RerunTools []string

+ ToolCalls []schema.ToolCall

type ToolsNodeConfig

+ ToolArgumentsHandler func(ctx context.Context, name, arguments string) (string, error)

May 15, 2025

Changes in this version

type GraphCompileOption

+ func WithEagerExecution() GraphCompileOption

May 12, 2025

Changes in this version

type ToolsNodeConfig

+ ExecuteSequentially bool

Apr 21, 2025

Changes in this version

+ func RegisterValuesMergeFunc[T any](fn func([]T) (T, error))

Apr 14, 2025

Changes in this version

type NodePath

+ func (p *NodePath) GetPath() []string

type ToolsNodeConfig

+ UnknownToolsHandler func(ctx context.Context, name, input string) (string, error)

Apr 10, 2025

Changes in this version

+ var InterruptAndRerun = errors.New("interrupt and rerun")

type InterruptInfo

+ RerunNodes []string

Mar 28, 2025

Changes in this version

+ func GetToolCallID(ctx context.Context) string

+ func RegisterSerializableType[T any](name string) error

type ChainBranch

+ func NewChainMultiBranch[T any](cond GraphMultiBranchCondition[T]) *ChainBranch

+ func NewStreamChainMultiBranch[T any](cond StreamGraphMultiBranchCondition[T]) *ChainBranch

+ type CheckPointStore interface

+ Get func(ctx context.Context, checkPointID string) ([]byte, bool, error)

+ Set func(ctx context.Context, checkPointID string, checkPoint []byte) error

type GraphBranch

+ func NewGraphMultiBranch[T any](condition GraphMultiBranchCondition[T], endNodes map[string]bool) *GraphBranch

+ func NewStreamGraphMultiBranch[T any](condition StreamGraphMultiBranchCondition[T], endNodes map[string]bool) *GraphBranch

type GraphCompileOption

+ func WithCheckPointStore(store CheckPointStore) GraphCompileOption

+ func WithInterruptAfterNodes(nodes []string) GraphCompileOption

+ func WithInterruptBeforeNodes(nodes []string) GraphCompileOption

type GraphInfo

+ DataEdges map[string][]string

+ NewGraphOptions []NewGraphOption

+ type GraphMultiBranchCondition func(ctx context.Context, in T) (endNode map[string]bool, err error)

+ type InterruptInfo struct

+ AfterNodes []string

+ BeforeNodes []string

+ State any

+ SubGraphs map[string]*InterruptInfo

+ func ExtractInterruptInfo(err error) (info *InterruptInfo, existed bool)

type Option

+ func WithCheckPointID(checkPointID string) Option

+ func WithStateModifier(sm StateModifier) Option

+ type StateModifier func(ctx context.Context, path NodePath, state any) error

+ type StreamGraphMultiBranchCondition func(ctx context.Context, in *schema.StreamReader[T]) (endNodes map[string]bool, err error)

type Workflow

+ func (wf *Workflow[I, O]) AddBranch(fromNodeKey string, branch *GraphBranch) *WorkflowBranch

+ func (wf *Workflow[I, O]) AddPassthroughNode(key string, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) End() *WorkflowNode

+ type WorkflowAddInputOpt func(*workflowAddInputOpts)

+ func WithNoDirectDependency() WorkflowAddInputOpt

+ type WorkflowBranch struct

type WorkflowNode

+ func (n *WorkflowNode) AddDependency(fromNodeKey string) *WorkflowNode

+ func (n *WorkflowNode) AddInputWithOptions(fromNodeKey string, inputs []*FieldMapping, opts ...WorkflowAddInputOpt) *WorkflowNode

+ func (n *WorkflowNode) SetStaticValue(path FieldPath, value any) *WorkflowNode

Mar 19, 2025

Changes in this version

type FieldMapping

+ func FromFieldPath(fromFieldPath FieldPath) *FieldMapping

+ func MapFieldPaths(fromFieldPath, toFieldPath FieldPath) *FieldMapping

+ func ToFieldPath(toFieldPath FieldPath) *FieldMapping

+ type FieldPath []string

Mar 12, 2025

Changes in this version

type ToolsNodeOption

+ func WithToolList(tool ...tool.BaseTool) ToolsNodeOption

Feb 14, 2025

Changes in this version

+ func ProcessState[S any](ctx context.Context, handler func(context.Context, S) error) error

Jan 26, 2025

Changes in this version

+ const ComponentOfWorkflow

+ type FieldMapping struct

+ func FromField(from string) *FieldMapping

+ func MapFields(from, to string) *FieldMapping

+ func ToField(to string) *FieldMapping

+ func (m *FieldMapping) String() string

type GraphCompileOption

+ func WithGetStateEnable(enabled bool) GraphCompileOption

type GraphNodeInfo

+ Mappings []*FieldMapping

+ type Workflow struct

+ func NewWorkflow[I, O any](opts ...NewGraphOption) *Workflow[I, O]

+ func (wf *Workflow[I, O]) AddChatModelNode(key string, chatModel model.ChatModel, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) AddChatTemplateNode(key string, chatTemplate prompt.ChatTemplate, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) AddDocumentTransformerNode(key string, transformer document.Transformer, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) AddEmbeddingNode(key string, embedding embedding.Embedder, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) AddEnd(fromNodeKey string, inputs ...*FieldMapping) *Workflow[I, O]

+ func (wf *Workflow[I, O]) AddGraphNode(key string, graph AnyGraph, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) AddIndexerNode(key string, indexer indexer.Indexer, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) AddLambdaNode(key string, lambda *Lambda, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) AddLoaderNode(key string, loader document.Loader, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) AddRetrieverNode(key string, retriever retriever.Retriever, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) AddToolsNode(key string, tools *ToolsNode, opts ...GraphAddNodeOpt) *WorkflowNode

+ func (wf *Workflow[I, O]) Compile(ctx context.Context, opts ...GraphCompileOption) (Runnable[I, O], error)

+ type WorkflowNode struct

+ func (n *WorkflowNode) AddInput(fromNodeKey string, inputs ...*FieldMapping) *WorkflowNode

Jan 6, 2025

Changes in this version

type GraphInfo

+ Name string

+ type NodePath struct

+ func NewNodePath(path ...string) *NodePath

type Option

+ func (o Option) DesignateNodeWithPath(path ...*NodePath) Option

Dec 26, 2024

Changes in this version

+ var ErrChainCompiled = errors.New("chain has been compiled, cannot be modified")

+ var ErrGraphCompiled = errors.New("graph has been compiled, cannot be modified")

+ type NewGraphOption func(ngo *newGraphOptions)

+ func WithGenLocalState[S any](gls GenLocalState[S]) NewGraphOption

Dec 11, 2024

Changes in this version

+ const ComponentOfChain

+ const ComponentOfGraph

+ const ComponentOfLambda

+ const ComponentOfPassthrough

+ const ComponentOfStateChain

+ const ComponentOfStateGraph

+ const ComponentOfToolsNode

+ const ComponentOfUnknown

+ const END

+ const START

+ var ErrExceedMaxSteps = errors.New("exceeds max steps")

+ func GetState[S any](ctx context.Context) (S, error)

+ func InitGraphCompileCallbacks(cbs []GraphCompileCallback)

+ func RegisterStreamChunkConcatFunc[T any](fn func([]T) (T, error))

+ type AnyGraph interface

+ type Chain struct

+ func NewChain[I, O any]() *Chain[I, O]

+ func (c *Chain[I, O]) AppendBranch(b *ChainBranch) *Chain[I, O]

+ func (c *Chain[I, O]) AppendChatModel(node model.ChatModel, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendChatTemplate(node prompt.ChatTemplate, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendDocumentTransformer(node document.Transformer, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendEmbedding(node embedding.Embedder, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendGraph(node AnyGraph, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendIndexer(node indexer.Indexer, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendLambda(node *Lambda, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendLoader(node document.Loader, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendLoaderSplitter(node document.LoaderSplitter, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendParallel(p *Parallel) *Chain[I, O]

+ func (c *Chain[I, O]) AppendPassthrough(opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendRetriever(node retriever.Retriever, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) AppendToolsNode(node *ToolsNode, opts ...GraphAddNodeOpt) *Chain[I, O]

+ func (c *Chain[I, O]) Compile(ctx context.Context, opts ...GraphCompileOption) (Runnable[I, O], error)

+ type ChainBranch struct

+ func NewChainBranch[T any](cond GraphBranchCondition[T]) *ChainBranch

+ func NewStreamChainBranch[T any](cond StreamGraphBranchCondition[T]) *ChainBranch

+ func (cb *ChainBranch) AddChatModel(key string, node model.ChatModel, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddChatTemplate(key string, node prompt.ChatTemplate, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddDocumentTransformer(key string, node document.Transformer, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddEmbedding(key string, node embedding.Embedder, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddGraph(key string, node AnyGraph, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddIndexer(key string, node indexer.Indexer, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddLambda(key string, node *Lambda, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddLoader(key string, node document.Loader, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddLoaderSplitter(key string, node document.LoaderSplitter, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddPassthrough(key string, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddRetriever(key string, node retriever.Retriever, opts ...GraphAddNodeOpt) *ChainBranch

+ func (cb *ChainBranch) AddToolsNode(key string, node *ToolsNode, opts ...GraphAddNodeOpt) *ChainBranch

+ type Collect func(ctx context.Context, input *schema.StreamReader[I], opts ...TOption) (output O, err error)

+ type CollectWOOpt func(ctx context.Context, input *schema.StreamReader[I]) (output O, err error)

+ type GenLocalState func(ctx context.Context) (state S)

+ type Graph struct

+ func NewGraph[I, O any]() *Graph[I, O]

+ func (g *Graph[I, O]) Compile(ctx context.Context, opts ...GraphCompileOption) (Runnable[I, O], error)

+ func (g Graph) AddBranch(startNode string, branch *GraphBranch) (err error)

+ func (g Graph) AddChatModelNode(key string, node model.ChatModel, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddChatTemplateNode(key string, node prompt.ChatTemplate, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddDocumentTransformerNode(key string, node document.Transformer, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddEdge(startNode, endNode string) (err error)

+ func (g Graph) AddEmbeddingNode(key string, node embedding.Embedder, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddGraphNode(key string, node AnyGraph, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddIndexerNode(key string, node indexer.Indexer, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddLambdaNode(key string, node *Lambda, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddLoaderNode(key string, node document.Loader, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddLoaderSplitterNode(key string, node document.LoaderSplitter, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddPassthroughNode(key string, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddRetrieverNode(key string, node retriever.Retriever, opts ...GraphAddNodeOpt) error

+ func (g Graph) AddToolsNode(key string, node *ToolsNode, opts ...GraphAddNodeOpt) error

+ func (g Graph) GetType() string

+ type GraphAddNodeOpt func(o *graphAddNodeOpts)

+ func WithGraphCompileOptions(opts ...GraphCompileOption) GraphAddNodeOpt

+ func WithInputKey(k string) GraphAddNodeOpt

+ func WithNodeKey(key string) GraphAddNodeOpt

+ func WithNodeName(n string) GraphAddNodeOpt

+ func WithOutputKey(k string) GraphAddNodeOpt

+ func WithStatePostHandler[O, S any](post StatePostHandler[O, S]) GraphAddNodeOpt

+ func WithStatePreHandler[I, S any](pre StatePreHandler[I, S]) GraphAddNodeOpt

+ func WithStreamStatePostHandler[O, S any](post StreamStatePostHandler[O, S]) GraphAddNodeOpt

+ func WithStreamStatePreHandler[I, S any](pre StreamStatePreHandler[I, S]) GraphAddNodeOpt

+ type GraphBranch struct

+ func NewGraphBranch[T any](condition GraphBranchCondition[T], endNodes map[string]bool) *GraphBranch

+ func NewStreamGraphBranch[T any](condition StreamGraphBranchCondition[T], endNodes map[string]bool) *GraphBranch

+ func (gb *GraphBranch) GetEndNode() map[string]bool

+ type GraphBranchCondition func(ctx context.Context, in T) (endNode string, err error)

+ type GraphCompileCallback interface

+ OnFinish func(ctx context.Context, info *GraphInfo)

+ type GraphCompileOption func(*graphCompileOptions)

+ func WithGraphCompileCallbacks(cbs ...GraphCompileCallback) GraphCompileOption

+ func WithGraphKey(graphKey string) GraphCompileOption

+ func WithGraphName(graphName string) GraphCompileOption

+ func WithMaxRunSteps(maxSteps int) GraphCompileOption

+ func WithNodeTriggerMode(triggerMode NodeTriggerMode) GraphCompileOption

+ type GraphInfo struct

+ Branches map[string][]GraphBranch

+ CompileOptions []GraphCompileOption

+ Edges map[string][]string

+ GenStateFn func(context.Context) any

+ InputType reflect.Type

+ Key string

+ Nodes map[string]GraphNodeInfo

+ OutputType reflect.Type

+ type GraphNodeInfo struct

+ Component components.Component

+ GraphAddNodeOpts []GraphAddNodeOpt

+ GraphInfo *GraphInfo

+ InputKey string

+ InputType reflect.Type

+ Instance any

+ Name string

+ OutputKey string

+ OutputType reflect.Type

+ type Invoke func(ctx context.Context, input I, opts ...TOption) (output O, err error)

+ type InvokeWOOpt func(ctx context.Context, input I) (output O, err error)

+ type Lambda struct

+ func AnyLambda[I, O, TOption any](i Invoke[I, O, TOption], s Stream[I, O, TOption], c Collect[I, O, TOption], ...) (*Lambda, error)

+ func CollectableLambdaWithOption[I, O, TOption any](c Collect[I, O, TOption], opts ...LambdaOpt) *Lambda

+ func CollectableLambda[I, O any](c CollectWOOpt[I, O], opts ...LambdaOpt) *Lambda

+ func InvokableLambdaWithOption[I, O, TOption any](i Invoke[I, O, TOption], opts ...LambdaOpt) *Lambda

+ func InvokableLambda[I, O any](i InvokeWOOpt[I, O], opts ...LambdaOpt) *Lambda

+ func MessageParser[T any](p schema.MessageParser[T], opts ...LambdaOpt) *Lambda

+ func StreamableLambdaWithOption[I, O, TOption any](s Stream[I, O, TOption], opts ...LambdaOpt) *Lambda

+ func StreamableLambda[I, O any](s StreamWOOpt[I, O], opts ...LambdaOpt) *Lambda

+ func ToList[I any](opts ...LambdaOpt) *Lambda

+ func TransformableLambdaWithOption[I, O, TOption any](t Transform[I, O, TOption], opts ...LambdaOpt) *Lambda

+ func TransformableLambda[I, O any](t TransformWOOpts[I, O], opts ...LambdaOpt) *Lambda

+ type LambdaOpt func(o *lambdaOpts)

+ func WithLambdaCallbackEnable(y bool) LambdaOpt

+ func WithLambdaType(t string) LambdaOpt

+ type NodeTriggerMode string

+ const AllPredecessor

+ const AnyPredecessor

+ type Option struct

+ func WithCallbacks(cbs ...callbacks.Handler) Option

+ func WithChatModelOption(opts ...model.Option) Option

+ func WithChatTemplateOption(opts ...prompt.Option) Option

+ func WithDocumentTransformerOption(opts ...document.TransformerOption) Option

+ func WithEmbeddingOption(opts ...embedding.Option) Option

+ func WithGraphCallbacks(cbs ...callbacks.Handler) Option

+ func WithGraphRunOption(opt Option) Option

+ func WithIndexerOption(opts ...indexer.Option) Option

+ func WithLambdaOption(opts ...any) Option

+ func WithLoaderOption(opts ...document.LoaderOption) Option

+ func WithLoaderSplitterOption(opts ...document.LoaderSplitterOption) Option

+ func WithNodeCallbacks(cbs ...callbacks.Handler) Option

+ func WithRetrieverOption(opts ...retriever.Option) Option

+ func WithRuntimeMaxSteps(maxSteps int) Option

+ func WithToolsNodeOption(opts ...ToolsNodeOption) Option

+ func (o Option) DesignateNode(key ...string) Option

+ type Parallel struct

+ func NewParallel() *Parallel

+ func (p *Parallel) AddChatModel(outputKey string, node model.ChatModel, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddChatTemplate(outputKey string, node prompt.ChatTemplate, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddDocumentTransformer(outputKey string, node document.Transformer, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddEmbedding(outputKey string, node embedding.Embedder, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddGraph(outputKey string, node AnyGraph, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddIndexer(outputKey string, node indexer.Indexer, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddLambda(outputKey string, node *Lambda, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddLoader(outputKey string, node document.Loader, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddLoaderSplitter(outputKey string, node document.LoaderSplitter, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddPassthrough(outputKey string, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddRetriever(outputKey string, node retriever.Retriever, opts ...GraphAddNodeOpt) *Parallel

+ func (p *Parallel) AddToolsNode(outputKey string, node *ToolsNode, opts ...GraphAddNodeOpt) *Parallel

+ type Runnable interface

+ Collect func(ctx context.Context, input *schema.StreamReader[I], opts ...Option) (output O, err error)

+ Invoke func(ctx context.Context, input I, opts ...Option) (output O, err error)

+ Stream func(ctx context.Context, input I, opts ...Option) (output *schema.StreamReader[O], err error)

+ Transform func(ctx context.Context, input *schema.StreamReader[I], opts ...Option) (output *schema.StreamReader[O], err error)

+ type StateChain struct

+ func NewStateChain[I, O, S any](gen GenLocalState[S]) *StateChain[I, O, S]

+ func (s *StateChain[I, O, S]) Compile(ctx context.Context, opts ...GraphCompileOption) (Runnable[I, O], error)

+ type StateGraph struct

+ func NewStateGraph[I, O, S any](gen GenLocalState[S]) *StateGraph[I, O, S]

+ func (g StateGraph) AddBranch(startNode string, branch *GraphBranch) (err error)

+ func (g StateGraph) AddChatModelNode(key string, node model.ChatModel, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddChatTemplateNode(key string, node prompt.ChatTemplate, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddDocumentTransformerNode(key string, node document.Transformer, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddEdge(startNode, endNode string) (err error)

+ func (g StateGraph) AddEmbeddingNode(key string, node embedding.Embedder, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddGraphNode(key string, node AnyGraph, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddIndexerNode(key string, node indexer.Indexer, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddLambdaNode(key string, node *Lambda, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddLoaderNode(key string, node document.Loader, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddLoaderSplitterNode(key string, node document.LoaderSplitter, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddPassthroughNode(key string, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddRetrieverNode(key string, node retriever.Retriever, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) AddToolsNode(key string, node *ToolsNode, opts ...GraphAddNodeOpt) error

+ func (g StateGraph) GetType() string

+ func (s *StateGraph[I, O, S]) Compile(ctx context.Context, opts ...GraphCompileOption) (Runnable[I, O], error)

+ type StatePostHandler func(ctx context.Context, out O, state S) (O, error)

+ type StatePreHandler func(ctx context.Context, in I, state S) (I, error)

+ type Stream func(ctx context.Context, input I, opts ...TOption) (output *schema.StreamReader[O], err error)

+ type StreamGraphBranchCondition func(ctx context.Context, in *schema.StreamReader[T]) (endNode string, err error)

+ type StreamStatePostHandler func(ctx context.Context, out *schema.StreamReader[O], state S) (*schema.StreamReader[O], error)

+ type StreamStatePreHandler func(ctx context.Context, in *schema.StreamReader[I], state S) (*schema.StreamReader[I], error)

+ type StreamWOOpt func(ctx context.Context, input I) (output *schema.StreamReader[O], err error)

+ type ToolsNode struct

+ func NewToolNode(ctx context.Context, conf *ToolsNodeConfig) (*ToolsNode, error)

+ func (tn *ToolsNode) GetType() string

+ func (tn *ToolsNode) Invoke(ctx context.Context, input *schema.Message, opts ...ToolsNodeOption) ([]*schema.Message, error)

+ func (tn *ToolsNode) Stream(ctx context.Context, input *schema.Message, opts ...ToolsNodeOption) (*schema.StreamReader[[]*schema.Message], error)

+ type ToolsNodeConfig struct

+ Tools []tool.BaseTool

+ type ToolsNodeOption func(o *toolsNodeOptions)

+ func WithToolOption(opts ...tool.Option) ToolsNodeOption

+ type Transform func(ctx context.Context, input *schema.StreamReader[I], opts ...TOption) (output *schema.StreamReader[O], err error)

+ type TransformWOOpts func(ctx context.Context, input *schema.StreamReader[I]) (output *schema.StreamReader[O], err error)