multiagent

type AggregatedResult struct {
	Content      string
	TokensUsed   int
	Cost         float64
	Duration     time.Duration
	SourceCount  int
	FailedCount  int
	Metadata     map[string]any
	FinishReason string
}

type AggregationStrategy string

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

type DedupResultAggregator struct{}

type FailurePolicy string

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

type ModeStrategy interface {
	// Name returns the unique mode identifier.
	Name() string
	// Execute runs the mode's logic using the provided agents and input.
	Execute(ctx context.Context, agents []agent.Agent, input *agent.Input) (*agent.Output, error)
}

type QueryDecomposer interface {
	Decompose(ctx context.Context, query string) ([]string, error)
}

type RetrievalResultAggregator interface {
	Aggregate(ctx context.Context, resultsByQuery map[string][]rag.RetrievalResult) ([]rag.RetrievalResult, error)
}

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

type RetrievalWorker interface {
	Retrieve(ctx context.Context, query string) ([]rag.RetrievalResult, error)
}

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

type StaticSplitter struct {
	Agents  []agent.Agent
	Weights map[string]float64 // agent_id -> weight (optional)
}

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

type SupervisorConfig struct {
	AggregationStrategy AggregationStrategy
	FailurePolicy       FailurePolicy
	MaxRetries          int
	TaskTimeout         time.Duration
}

type TaskSplitter interface {
	Split(ctx context.Context, input *agent.Input) ([]WorkerTask, error)
}

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

type WorkerPoolConfig struct {
	FailurePolicy FailurePolicy
	MaxRetries    int
	TaskTimeout   time.Duration
}

type WorkerResult struct {
	AgentID      string
	Content      string
	TokensUsed   int
	Cost         float64
	Duration     time.Duration
	Score        float64 // confidence / quality score (used by BestOfN)
	Weight       float64 // agent weight (used by WeightedMerge)
	Err          error
	FinishReason string
	Metadata     map[string]any
}

type WorkerTask struct {
	AgentID   string
	Agent     agent.Agent
	Input     *agent.Input
	Weight    float64  // used by WeightedMerge aggregation
	ToolScope []string // allowed tool names (empty = all tools)
}