subagent

type AgentFactory func(provider provider.Provider, registry ToolRegistry, toolsSchema []map[string]interface{}, systemPrompt string) AgentRunner

type AgentRunner interface {
	RunConversation(ctx context.Context, input string) (string, error)
}

type Config struct {
	MaxConcurrent int           `json:"max_concurrent"` // Max parallel subagents
	MaxDepth      int           `json:"max_depth"`      // Max recursion depth
	Timeout       time.Duration `json:"timeout"`        // Task timeout
	EnableNested  bool          `json:"enable_nested"`  // Enable nested subagents
}

type DAGExecutor struct {

	// Configuration
	MaxConcurrency int
	Timeout        time.Duration
	// contains filtered or unexported fields
}

type DAGExecutorConfig struct {
	MaxConcurrency int
	Timeout        time.Duration
}

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

type Result struct {
	TaskID     string        `json:"task_id"`
	Success    bool          `json:"success"`
	Output     string        `json:"output"`
	Error      string        `json:"error,omitempty"`
	Duration   time.Duration `json:"duration"`
	SubResults []Result      `json:"sub_results,omitempty"`
	CreatedAt  time.Time     `json:"created_at"`
}

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

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

type SubTaskNode struct {
	ID           string
	Description  string
	Role         string   // researcher, coder, reviewer, planner, etc.
	Tools        []string // Tools available to this sub-agent
	Priority     int
	Dependencies []string // IDs of tasks that must complete first
	Status       SubTaskStatus
	Result       string
	Error        string
	Agent        *SubAgent
	StartTime    time.Time
	EndTime      time.Time
	Duration     time.Duration
	Retries      int
	MaxRetries   int
}

type SubTaskStatus string

type Task struct {
	ID          string                 `json:"id"`
	Description string                 `json:"description"`
	Input       string                 `json:"input"`
	Tools       []string               `json:"tools,omitempty"` // Tools to enable for this task
	Context     map[string]interface{} `json:"context,omitempty"`
	ParentID    string                 `json:"parent_id,omitempty"`
	Depth       int                    `json:"depth"`
	Status      TaskStatus             `json:"status"`
	CreatedAt   time.Time              `json:"created_at"`
	StartedAt   *time.Time             `json:"started_at,omitempty"`
	CompletedAt *time.Time             `json:"completed_at,omitempty"`
	Cancelled   bool                   `json:"cancelled"`
	// contains filtered or unexported fields
}

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

type TaskStatus string

type Tool interface {
	Name() string
	Description() string
	Schema() map[string]interface{}
}

type ToolRegistry interface {
	List() []string
	Get(name string) (Tool, error)
}