collaboration

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

type CollaborationPattern string

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

type Coordinator interface {
	Coordinate(ctx context.Context, agents map[string]agent.Agent, input *agent.Input) (*agent.Output, error)
}

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

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

type Message struct {
	ID        string
	FromID    string
	ToID      string // 空表示广播
	Type      MessageType
	Content   string
	Metadata  map[string]any
	Timestamp time.Time
	Body      types.Message // Canonical message body bridge to Layer-0 types.Message
}

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

type MessageType string

type MultiAgentConfig struct {
	Pattern            CollaborationPattern `json:"pattern"`
	MaxRounds          int                  `json:"max_rounds"`
	ConsensusThreshold float64              `json:"consensus_threshold"`
	Timeout            time.Duration        `json:"timeout"`
	EnableVoting       bool                 `json:"enable_voting"`
	SharedState        SharedState          `json:"-"`
}

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

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

type PipelineConfig struct {
	Name           string        `json:"name"`
	Description    string        `json:"description"`
	MaxConcurrency int           `json:"max_concurrency"` // 最大并行角色数
	Timeout        time.Duration `json:"timeout"`         // 整体超时
	StopOnFailure  bool          `json:"stop_on_failure"` // 失败时停止
}

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

type RetryPolicy struct {
	MaxRetries int           `json:"max_retries"` // 最大重试次数
	Delay      time.Duration `json:"delay"`       // 重试间隔
	BackoffMul float64       `json:"backoff_mul"` // 退避乘数
}

type RoleCapability struct {
	Name        string   `json:"name"`         // 能力名称
	Description string   `json:"description"`  // 能力描述
	Tools       []string `json:"tools"`        // 可用工具列表
	InputTypes  []string `json:"input_types"`  // 接受的输入类型
	OutputTypes []string `json:"output_types"` // 产出的输出类型
}

type RoleDefinition struct {
	Type          RoleType         `json:"type"`
	Name          string           `json:"name"`
	Description   string           `json:"description"`
	SystemPrompt  string           `json:"system_prompt"` // 角色的系统提示词
	Capabilities  []RoleCapability `json:"capabilities"`
	Dependencies  []RoleType       `json:"dependencies"`   // 依赖的前置角色
	MaxConcurrent int              `json:"max_concurrent"` // 最大并发实例数
	Timeout       time.Duration    `json:"timeout"`        // 角色执行超时
	RetryPolicy   *RetryPolicy     `json:"retry_policy"`   // 重试策略
	Priority      int              `json:"priority"`       // 优先级 (越高越优先)
}

type RoleExecuteFunc func(ctx context.Context, role *RoleDefinition, input any) (any, error)

type RoleInstance struct {
	ID          string         `json:"id"`
	Definition  RoleDefinition `json:"definition"`
	AgentID     string         `json:"agent_id"` // 绑定的 Agent ID
	Status      RoleStatus     `json:"status"`
	Input       any            `json:"input,omitempty"`
	Output      any            `json:"output,omitempty"`
	Error       string         `json:"error,omitempty"`
	StartedAt   time.Time      `json:"started_at"`
	CompletedAt *time.Time     `json:"completed_at,omitempty"`
	Metadata    map[string]any `json:"metadata,omitempty"`
}

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

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

type RoleStatus string

type RoleTransition struct {
	FromRole  RoleType  `json:"from_role"`
	ToRole    RoleType  `json:"to_role"`
	Data      any       `json:"data"`
	Timestamp time.Time `json:"timestamp"`
}

type RoleType string

type SharedState interface {
	Get(ctx context.Context, key string) (any, bool)
	Set(ctx context.Context, key string, value any) error
	Watch(ctx context.Context, key string) <-chan any
	Snapshot(ctx context.Context) map[string]any
}