compose

package

Go to main page

Versions in this module

v0

v0.3.16

Mar 13, 2025

v0.3.15

Mar 12, 2025

Changes in this version

type ToolsNodeOption

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

v0.3.14

Feb 26, 2025

v0.3.13

Feb 21, 2025

v0.3.12

Feb 21, 2025

v0.3.11

Feb 20, 2025

v0.3.10

Feb 14, 2025

Changes in this version

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

v0.3.9

Feb 7, 2025

v0.3.8

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

v0.3.7

Jan 15, 2025

v0.3.7-alpha

Jan 16, 2025

v0.3.6

Jan 13, 2025

v0.3.5

Jan 9, 2025

v0.3.4

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

v0.3.3

Dec 26, 2024

v0.3.2

Dec 26, 2024

v0.3.1

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

v0.3.1-alpha

Dec 23, 2024

v0.3.0

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL