executor

type AgentContribution struct {
	ID         string // Agent identifier
	Capability string // Agent's announced capability
	Round      int    // Which round this was (0 = first contribution from another agent)
	Output     string // The agent's output
}

type AgentIdentity struct {
	Name string // Agent name (e.g., "researcher", "writer", or workflow name for main)
	Role string // Agent role (for dynamic sub-agents, same as name; for static agents, defined role)
}

type AgentState struct {
	AgentID     string
	Status      string // "replay", "monitoring", "deliberating", "executing"
	Capability  string
	CurrentTask string
	LastSeen    time.Time
}

type Config struct {
	// Core (required)
	Workflow        *agentfile.Workflow
	Provider        llm.Provider
	ProviderFactory llm.ProviderFactory
	Registry        *tools.Registry
	Policy          *policy.Policy

	// Debug mode — when true, logs full content (prompts, responses, tool outputs).
	Debug bool

	// MCP
	MCPManager *mcp.Manager

	// Skills
	SkillRefs []skills.SkillRef

	// Session
	Session           *session.Session
	SessionManager    session.SessionManager
	PersistentSession bool

	// Supervision
	CheckpointStore checkpoint.CheckpointStore
	Supervisor      supervision.Supervisor
	HumanAvailable  bool
	HumanInputChan  chan string

	// Security
	SecurityVerifier      *security.Verifier
	SecurityResearchScope string

	// Timeouts for network operations (seconds). Zero means use default.
	TimeoutMCP       int
	TimeoutWebSearch int
	TimeoutWebFetch  int

	// Observation extraction for semantic memory
	ObservationExtractor ObservationExtractor
	ObservationStore     ObservationStore

	// Metrics collector for heartbeat reporting (optional, used by serve mode)
	MetricsCollector MetricsCollector

	// Swarm collaboration (nil = non-swarm mode)
	InterruptBuffer  *InterruptBuffer
	DiscussPublisher func(goalName, content string)

	// Workspace context injected into system prompt so the agent
	// knows the project layout without needing to discover it.
	WorkspaceContext string

	// Hooks registry for cross-cutting concerns (logging, telemetry, metrics).
	// If nil, a fresh registry is created.
	Hooks *hooks.Registry
}

type ConvergenceIteration struct {
	N      int    // Iteration number (1-indexed)
	Output string // The output from this iteration
}

type ConvergenceResult struct {
	Converged  bool   // true if the goal converged before hitting the limit
	Iterations int    // number of iterations executed
	Output     string // final output (last substantive iteration)
}

type DiscussMessage struct {
	From      string
	Timestamp time.Time
	Content   string
	Signal    string // "CLAIM", "NEED_INFO", "DONE", or empty
}

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

type GoalOutput struct {
	ID     string // Goal identifier
	Output string // The LLM's response for this goal
}

type GoalResult struct {
	Output        string
	ToolCallsMade bool
}

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

type InterruptMessage struct {
	From      string    // Agent name or "operator"
	Timestamp time.Time // When the message was published
	Content   string    // Raw message content
	TaskID    string    // Task ID from the NATS subject
}

type MetricsCollector interface {
	RecordLLMCall(inputTokens, outputTokens, cacheCreation, cacheRead int, latencyMs int64)
	RecordSupervision(approved bool)
	SetSubagents(count int)
}

type ObservationExtractor interface {
	Extract(ctx context.Context, stepName, stepType, output string) (any, error)
}

type ObservationStore interface {
	StoreObservation(ctx context.Context, obs any) error
	QueryRelevantObservations(ctx context.Context, query string, limit int) ([]any, error)
}

type Result struct {
	Status     Status
	Outputs    map[string]string
	Iterations map[string]int
	Error      string
}

type Status string

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

type TaskDiscussion struct {
	TaskID   string
	Messages []DiscussMessage
}

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