engine

type DAGStrategy struct{}

type ExecutionMode string

type ExecutionNode struct {
	ID           string
	Step         core.StepProtocol
	Dependencies []string // 依赖的节点 ID
	Input        core.StepInput
}

type ExecutionResult struct {
	Outputs map[string]core.StepOutput // nodeID -> output
	Errors  map[string]error           // nodeID -> error (if any)
}

type Executor struct {
	// contains filtered or unexported fields
}

type ParallelStrategy struct{}

type RouteSelector func(ctx context.Context, input core.StepInput, nodes []*ExecutionNode) (*ExecutionNode, error)

type RoutingStrategy struct {
	Selector RouteSelector
}

type ScheduleStrategy interface {
	Schedule(ctx context.Context, nodes []*ExecutionNode, runner StepRunner) (*ExecutionResult, error)
}

type SequentialStrategy struct{}

type StepDependencies struct {
	Gateway       core.GatewayLike
	ToolRegistry  core.ToolRegistry
	HumanHandler  core.HumanInputHandler
	AgentExecutor core.AgentExecutor
	CodeHandler   workflowsteps.CodeHandler

	HybridRetriever   workflowsteps.HybridRetriever
	MultiHopReasoner  workflowsteps.MultiHopReasoner
	RetrievalReranker workflowsteps.RetrievalReranker
}

type StepRunner func(ctx context.Context, step core.StepProtocol, input core.StepInput) (core.StepOutput, error)

type StepSpec struct {
	ID           string
	Type         core.StepType
	Model        string
	Prompt       string
	Temperature  float64
	MaxTokens    int
	ToolName     string
	ToolParams   map[string]any
	InputPrompt  string
	InputType    string
	Options      []string
	Timeout      time.Duration
	Query        string
	Dependencies []string
	Input        core.StepInput
}