master

type AgentTask struct {
	Agent   domain.DomainAgent
	SubTask *sdktypes.Task
}

type DataInsightsInfo struct {
	KeyDataPoints     []string `json:"key_data_points"`
	DataRelationships string   `json:"data_relationships"`
}

type IntelligentSummary struct {
	Summary            string            `json:"summary"`
	KeyFindings        []string          `json:"key_findings"`
	AgentContributions map[string]string `json:"agent_contributions"`
	DataInsights       DataInsightsInfo  `json:"data_insights"`
	Recommendations    []string          `json:"recommendations"`
	Confidence         float64           `json:"confidence"`
}

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

type MergeStrategy string

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

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

type StreamMergerConfig struct {
	BufferSize             int           `yaml:"buffer_size"`              // 缓冲区大小
	OrderByTimestamp       bool          `yaml:"order_by_timestamp"`       // 是否按时间戳排序
	MergeTimeout           time.Duration `yaml:"merge_timeout"`            // 合并超时时间
	EnableProgressTracking bool          `yaml:"enable_progress_tracking"` // 启用进度跟踪
	SortBufferSize         int           `yaml:"sort_buffer_size"`         // 排序缓冲区大小
}

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

type StreamingExecutorConfig struct {
	StreamMerger *StreamMerger
	ResultMerger *ResultMerger
	AgentName    string
}

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