Versions in this module Expand all Collapse all v1 v1.4.6 Mar 3, 2026 Changes in this version + func DefaultStepRunner(ctx context.Context, step core.StepProtocol, input core.StepInput) (core.StepOutput, error) + type DAGStrategy struct + func (s *DAGStrategy) Schedule(ctx context.Context, nodes []*ExecutionNode, runner StepRunner) (*ExecutionResult, error) + type ExecutionMode string + const ModeDAG + const ModeParallel + const ModeRouting + const ModeSequential + type ExecutionNode struct + Dependencies []string + ID string + Input core.StepInput + Step core.StepProtocol + func BuildExecutionNode(spec StepSpec, deps StepDependencies) (*ExecutionNode, error) + type ExecutionResult struct + Errors map[string]error + Outputs map[string]core.StepOutput + type Executor struct + func NewExecutor() *Executor + func (e *Executor) Execute(ctx context.Context, mode ExecutionMode, nodes []*ExecutionNode, ...) (*ExecutionResult, error) + func (e *Executor) RegisterStrategy(mode ExecutionMode, strategy ScheduleStrategy) + type ParallelStrategy struct + func (s *ParallelStrategy) Schedule(ctx context.Context, nodes []*ExecutionNode, runner StepRunner) (*ExecutionResult, error) + type RouteSelector func(ctx context.Context, input core.StepInput, nodes []*ExecutionNode) (*ExecutionNode, error) + type RoutingStrategy struct + Selector RouteSelector + func (s *RoutingStrategy) Schedule(ctx context.Context, nodes []*ExecutionNode, runner StepRunner) (*ExecutionResult, error) + type ScheduleStrategy interface + Schedule func(ctx context.Context, nodes []*ExecutionNode, runner StepRunner) (*ExecutionResult, error) + type SequentialStrategy struct + func (s *SequentialStrategy) Schedule(ctx context.Context, nodes []*ExecutionNode, runner StepRunner) (*ExecutionResult, error) + type StepDependencies struct + AgentExecutor core.AgentExecutor + CodeHandler workflowsteps.CodeHandler + Gateway core.GatewayLike + HumanHandler core.HumanInputHandler + HybridRetriever workflowsteps.HybridRetriever + MultiHopReasoner workflowsteps.MultiHopReasoner + RetrievalReranker workflowsteps.RetrievalReranker + ToolRegistry core.ToolRegistry + type StepRunner func(ctx context.Context, step core.StepProtocol, input core.StepInput) (core.StepOutput, error) + type StepSpec struct + Dependencies []string + ID string + Input core.StepInput + InputPrompt string + InputType string + MaxTokens int + Model string + Options []string + Prompt string + Query string + Temperature float64 + Timeout time.Duration + ToolName string + ToolParams map[string]any + Type core.StepType
Go to main page