workflow

type ActorEngine struct {
	// 嵌入原有引擎（保持兼容）
	*Engine
	// contains filtered or unexported fields
}

type ActorEngineConfig struct {
	// SystemName Actor 系统名称
	SystemName string

	// DefaultTimeout 默认超时时间
	DefaultTimeout time.Duration

	// MaxConcurrentAgents 最大并发 Agent 数
	MaxConcurrentAgents int

	// SupervisorStrategy Agent 监督策略
	SupervisorStrategy actor.SupervisorStrategy

	// EnableMetrics 启用指标收集
	EnableMetrics bool
}

type ActorEngineStats struct {
	ActiveAgents  int
	TotalActors   int64
	TotalMessages int64
	DeadLetters   int64
	ProcessedMsgs int64
	Uptime        time.Duration
}

type AgentEventType string

type AgentFactory interface {
	CreateAgent(ctx context.Context, ref *AgentRef, config map[string]any) (workflow.Agent, error)
}

type AgentRef struct {
	ID       string            `json:"id"`
	Template string            `json:"template"`
	Config   map[string]any    `json:"config,omitempty"`
	Inputs   map[string]string `json:"inputs,omitempty"`  // 输入映射
	Outputs  map[string]string `json:"outputs,omitempty"` // 输出映射
}

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

type AgentStreamEvent struct {
	Type      AgentEventType
	Timestamp time.Time
	Data      map[string]any
	Error     error
}

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

type Approver interface {
	Approve(ctx context.Context, output *StepOutput) (approved bool, reason string, err error)
}

type AsyncBranch struct {
	ID        string
	Name      string
	Status    AsyncBranchStatus
	CreatedAt time.Time
	StartedAt time.Time
	UpdatedAt time.Time
	Result    any
	Error     error
	Metadata  map[string]any
}

type AsyncBranchStatus string

type AsyncMetrics struct {
	TotalBranches     int           `json:"total_branches"`
	ActiveBranches    int           `json:"active_branches"`
	CompletedBranches int           `json:"completed_branches"`
	TotalRequests     int64         `json:"total_requests"`
	AverageLatency    time.Duration `json:"average_latency"`
	MaxConcurrent     int           `json:"max_concurrent"`
}

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

type BackoffType string

type BranchCondition struct {
	Name      string         `json:"name"`
	Condition string         `json:"condition"` // 条件表达式
	Agent     *AgentRef      `json:"agent"`     // 分支Agent
	Weight    int            `json:"weight"`    // 权重（用于概率选择）
	Priority  int            `json:"priority"`  // 优先级
	Metadata  map[string]any `json:"metadata"`
}

type BranchEvaluationResult struct {
	Name      string         `json:"name"`
	Condition string         `json:"condition"`
	Agent     *AgentRef      `json:"agent"`
	Matched   bool           `json:"matched"`
	Error     error          `json:"error,omitempty"`
	Duration  time.Duration  `json:"duration"`
	Metadata  map[string]any `json:"metadata"`
}

type CancelWorkflowMsg struct {
	ExecutionID string
}

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

type ConditionDef struct {
	Type   ConditionType   `json:"type"`             // and, or, not, custom
	Rules  []ConditionRule `json:"rules"`            // 条件规则
	Custom string          `json:"custom,omitempty"` // 自定义条件表达式
}

type ConditionLevel struct {
	Name       string            `json:"name"`
	Conditions []BranchCondition `json:"conditions"`
	Level      int               `json:"level"`
	Else       *ConditionLevel   `json:"else,omitempty"` // else分支
	Metadata   map[string]any    `json:"metadata"`
}

type ConditionRule struct {
	Variable string `json:"variable"` // 变量路径，如 "input.score"
	Operator string `json:"operator"` // eq, ne, gt, gte, lt, lte, in, nin, contains, regex
	Value    any    `json:"value"`    // 比较值
}

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

type ConditionType string

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

type ConditionalConfig struct {
	Name        string            `json:"name"`
	Conditions  []BranchCondition `json:"conditions"`
	Default     *AgentRef         `json:"default,omitempty"`
	Variables   map[string]any    `json:"variables,omitempty"`
	EvalTimeout time.Duration     `json:"eval_timeout,omitempty"`
}

type Constraint interface {
	Name() string
	Validate(value any) (bool, string) // 返回 (是否满足, 错误信息)
}

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

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

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

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

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

type EdgeDef struct {
	ID        string            `json:"id"`
	From      string            `json:"from"` // 源节点ID
	To        string            `json:"to"`   // 目标节点ID
	Label     string            `json:"label,omitempty"`
	Condition string            `json:"condition,omitempty"` // 边条件
	Metadata  map[string]string `json:"metadata,omitempty"`
}

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

type EngineConfig struct {
	// 并发配置
	MaxConcurrentWorkflows int `json:"max_concurrent_workflows"`
	MaxConcurrentNodes     int `json:"max_concurrent_nodes"`

	// 超时配置
	DefaultNodeTimeout     time.Duration `json:"default_node_timeout"`
	DefaultWorkflowTimeout time.Duration `json:"default_workflow_timeout"`

	// 重试配置
	DefaultRetryPolicy *RetryDef `json:"default_retry_policy"`

	// 缓存配置
	EnableResultCache bool          `json:"enable_result_cache"`
	CacheTTL          time.Duration `json:"cache_ttl"`

	// 监控配置
	EnableMetrics bool `json:"enable_metrics"`
	EnableTracing bool `json:"enable_tracing"`

	// 安全配置
	EnableSandbox bool `json:"enable_sandbox"`
	EnableAudit   bool `json:"enable_audit"`
}

type EngineMetrics struct {
	TotalExecutions      int64         `json:"total_executions"`
	RunningExecutions    int64         `json:"running_executions"`
	CompletedExecutions  int64         `json:"completed_executions"`
	FailedExecutions     int64         `json:"failed_executions"`
	AverageExecutionTime time.Duration `json:"average_execution_time"`
}

type ErrorHandling string

type EventBus interface {
	Publish(ctx context.Context, event *WorkflowEvent) error
	Subscribe(eventType string, handler EventHandler) error
	Unsubscribe(eventType string, handler EventHandler) error
}

type EventHandler func(ctx context.Context, event *WorkflowEvent) error

type ExecuteWorkflowMsg struct {
	Execution *WorkflowExecution
	ResultCh  chan *WorkflowResult
	ErrorCh   chan error
}

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

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

type Gate interface {
	ID() string
	Name() string
	Type() GateType
	Description() string

	// 评估决策门
	Evaluate(ctx context.Context, input *GateInput) *GateResult

	// 配置
	Config() *GateConfig
}

type GateConfig struct {
	ID          string
	Name        string
	Type        GateType
	Description string
	Enabled     bool
	FailOnError bool // 错误时是否视为失败
	Timeout     time.Duration
	Metadata    map[string]any
}

type GateInput struct {
	StepOutput      *StepOutput
	PreviousOutputs map[string]*StepOutput
	Project         any // 项目上下文
	Constraints     any // 约束条件
	SessionState    map[string]any
	Metadata        map[string]any
}

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

type GateResult struct {
	GateID      string
	GateName    string
	GateType    GateType
	Status      GateStatus
	Passed      bool
	Score       float64  // 0-100
	Reason      string   // 通过/失败理由
	Suggestions []string // 改进建议
	Details     map[string]any
	Timestamp   time.Time
	Duration    float64
}

type GateStatus string

type GateType string

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

type JoinType string

type LoggingConfig struct {
	Level   string   `json:"level"`   // debug, info, warn, error
	Format  string   `json:"format"`  // json, text
	Output  string   `json:"output"`  // stdout, file, syslog
	Exclude []string `json:"exclude"` // 排除的节点
	Include []string `json:"include"` // 包含的节点
}

type LoopDef struct {
	Type      LoopType `json:"type"`      // for, while, until, foreach
	Variable  string   `json:"variable"`  // 循环变量名
	Iterator  string   `json:"iterator"`  // 迭代器表达式
	Condition string   `json:"condition"` // 循环条件
	MaxLoops  int      `json:"max_loops"` // 最大循环次数(0=无限制)
}

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

type LoopType string

type MonitoringConfig struct {
	EnableMetrics bool   `json:"enable_metrics"`
	MetricsPath   string `json:"metrics_path"`
	EnableTracing bool   `json:"enable_tracing"`
	TracingPath   string `json:"tracing_path"`
}

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

type MultiLevelConditionalConfig struct {
	Name      string           `json:"name"`
	Levels    []ConditionLevel `json:"levels"`
	Variables map[string]any   `json:"variables,omitempty"`
	MaxDepth  int              `json:"max_depth"`
}

type NodeCompletedMsg struct {
	ExecutionID string
	NodeID      string
	Result      any
}

type NodeDef struct {
	ID        string         `json:"id"`
	Name      string         `json:"name"`
	Type      NodeType       `json:"type"`
	Position  Position       `json:"position"`
	Config    map[string]any `json:"config,omitempty"`
	Agent     *AgentRef      `json:"agent,omitempty"`     // Agent节点
	Condition *ConditionDef  `json:"condition,omitempty"` // 条件节点
	Loop      *LoopDef       `json:"loop,omitempty"`      // 循环节点
	Parallel  *ParallelDef   `json:"parallel,omitempty"`  // 并行节点
	Timeout   time.Duration  `json:"timeout,omitempty"`   // 超时时间
	Retry     *RetryDef      `json:"retry,omitempty"`     // 重试配置
}

type NodeFailedMsg struct {
	ExecutionID string
	NodeID      string
	Error       error
}

type NodeRef struct {
	ID     string `json:"id"`
	Name   string `json:"name"`
	Branch string `json:"branch,omitempty"`
}

type NodeResult struct {
	NodeID     string         `json:"node_id"`
	NodeName   string         `json:"node_name"`
	NodeType   NodeType       `json:"node_type"`
	Status     WorkflowStatus `json:"status"`
	StartTime  time.Time      `json:"start_time"`
	EndTime    time.Time      `json:"end_time"`
	Duration   time.Duration  `json:"duration"`
	Inputs     map[string]any `json:"inputs"`
	Outputs    map[string]any `json:"outputs"`
	Error      string         `json:"error,omitempty"`
	RetryCount int            `json:"retry_count"`
	Metadata   map[string]any `json:"metadata"`
}

type NodeType string

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

type ParallelBranch struct {
	Name    string
	ID      string
	Agent   AgentRef
	Timeout time.Duration
}

type ParallelBranchResult struct {
	Branch   ParallelBranch
	Success  bool
	Duration time.Duration
	Output   any
	Error    error
	Metrics  map[string]any
}

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

type ParallelConditionalConfig struct {
	Name        string            `json:"name"`
	Conditions  []BranchCondition `json:"conditions"`
	Default     *AgentRef         `json:"default,omitempty"`
	MaxParallel int               `json:"max_parallel"`
	Timeout     time.Duration     `json:"timeout"`
	Variables   map[string]any    `json:"variables,omitempty"`
	Strategy    ParallelStrategy  `json:"strategy"` // first, all, majority
}

type ParallelDef struct {
	Type     ParallelType `json:"type"`      // all, any, race
	Branches []NodeRef    `json:"branches"`  // 并行分支
	JoinType JoinType     `json:"join_type"` // wait, first, success, majority
}

type ParallelMetrics struct {
	TotalBranches     int           `json:"total_branches"`
	CompletedBranches int           `json:"completed_branches"`
	FailedBranches    int           `json:"failed_branches"`
	TotalDuration     time.Duration `json:"total_duration"`
	AverageDuration   time.Duration `json:"average_duration"`
	MaxDuration       time.Duration `json:"max_duration"`
	MinDuration       time.Duration `json:"min_duration"`
	StartTime         time.Time     `json:"start_time"`
	EndTime           time.Time     `json:"end_time"`
}

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

type ParallelStrategy string

type ParallelType string

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

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

type Position struct {
	X int `json:"x"`
	Y int `json:"y"`
}

type ProjectFilter struct {
	Type   string   `json:"type,omitempty"`
	Status string   `json:"status,omitempty"`
	Tags   []string `json:"tags,omitempty"`
	Limit  int      `json:"limit,omitempty"`
	Offset int      `json:"offset,omitempty"`
}

type ProjectManager interface {
	// 创建项目
	CreateProject(ctx context.Context, spec *ProjectSpec) (string, error)

	// 读取项目
	LoadProject(ctx context.Context, projectID string) (any, error)
	GetProjectMetadata(ctx context.Context, projectID string) (*ProjectMetadata, error)

	// 更新项目
	SaveProject(ctx context.Context, projectID string, data any) error
	UpdateProjectMetadata(ctx context.Context, projectID string, metadata *ProjectMetadata) error

	// 删除项目
	DeleteProject(ctx context.Context, projectID string) error

	// 列表操作
	ListProjects(ctx context.Context, filter *ProjectFilter) ([]*ProjectMetadata, error)

	// 归档和恢复
	ArchiveProject(ctx context.Context, projectID string) error
	UnarchiveProject(ctx context.Context, projectID string) error

	// 版本管理
	CreateSnapshot(ctx context.Context, projectID string, description string) (string, error)
	ListSnapshots(ctx context.Context, projectID string) ([]*ProjectSnapshot, error)
	RestoreSnapshot(ctx context.Context, projectID, snapshotID string) error
}

type ProjectMetadata struct {
	ID          string         `json:"id"`
	Name        string         `json:"name"`
	Description string         `json:"description"`
	Type        string         `json:"type"`
	Status      string         `json:"status"` // draft, in_progress, completed, archived
	CreatedAt   int64          `json:"created_at"`
	UpdatedAt   int64          `json:"updated_at"`
	CreatedBy   string         `json:"created_by,omitempty"`
	Tags        []string       `json:"tags,omitempty"`
	Metadata    map[string]any `json:"metadata,omitempty"`
	Size        int64          `json:"size,omitempty"`
}

type ProjectSnapshot struct {
	ID          string `json:"id"`
	ProjectID   string `json:"project_id"`
	Description string `json:"description"`
	CreatedAt   int64  `json:"created_at"`
	CreatedBy   string `json:"created_by,omitempty"`
	Metadata    any    `json:"metadata,omitempty"`
}

type ProjectSpec struct {
	Name        string         `json:"name"`
	Description string         `json:"description"`
	Type        string         `json:"type"`
	Metadata    map[string]any `json:"metadata,omitempty"`
	Tags        []string       `json:"tags,omitempty"`
}

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

type QualityEvaluator interface {
	Evaluate(ctx context.Context, output *StepOutput) (score float64, issues []string, err error)
}

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

type RetryDef struct {
	MaxAttempts int           `json:"max_attempts"` // 最大重试次数
	Delay       time.Duration `json:"delay"`        // 重试延迟
	Backoff     BackoffType   `json:"backoff"`      // 退避策略
	MaxDelay    time.Duration `json:"max_delay"`    // 最大延迟
}

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

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

type RouterEvent struct {
	Type          string
	RouterName    string
	SelectedSteps []string
	ExecutedSteps int
	Timestamp     time.Time
}

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

type RunEvent struct {
	Type         WorkflowEventType
	EventID      string
	WorkflowID   string
	WorkflowName string
	RunID        string
	StepID       string
	StepName     string
	Data         any
	Timestamp    time.Time
	Metadata     map[string]any
}

type RunMetrics struct {
	TotalExecutionTime float64
	TotalSteps         int
	SuccessfulSteps    int
	FailedSteps        int
	SkippedSteps       int
	TotalInputTokens   int
	TotalOutputTokens  int
	TotalTokens        int
	StepMetrics        map[string]*StepMetrics
}

type RunStatus string

type SecurityConfig struct {
	EnableAuth     bool     `json:"enable_auth"`
	AllowedRoles   []string `json:"allowed_roles"`
	DataEncryption bool     `json:"data_encryption"`
	AuditLogging   bool     `json:"audit_logging"`
	SandboxMode    bool     `json:"sandbox_mode"`
}

type SecurityManager struct {
	EnableAuth   bool     `json:"enable_auth"`
	AllowedRoles []string `json:"allowed_roles"`
	SandboxMode  bool     `json:"sandbox_mode"`
	EnableAudit  bool     `json:"enable_audit"`
}

type SessionManager interface {
	CreateSession(ctx context.Context, workflowID string) (*session.Session, error)
	GetSession(sessionID string) (*session.Session, error)
	CloseSession(sessionID string) error
}

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

type State interface {
	Name() string
	Description() string
	Handlers() []StateHandler
}

type StateHandler interface {
	OnEnter(ctx context.Context) error
	OnExit(ctx context.Context) error
}

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

type StateMachine interface {
	// 状态管理
	AddState(name string, handlers ...StateHandler) error
	AddTransition(from, to string, condition TransitionCondition) error
	GetState(name string) (State, error)
	GetCurrentState() string

	// 状态转移
	Transition(ctx context.Context, event string) (string, error)

	// 历史记录
	GetHistory() []*StateTransition
	GetLastTransition() *StateTransition

	// 持久化
	SaveState(ctx context.Context, stateData map[string]any) error
	LoadState(ctx context.Context) (map[string]any, error)
}

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

type StatePersistentStore interface {
	Save(ctx context.Context, stateID string, data map[string]any) error
	Load(ctx context.Context, stateID string) (map[string]any, error)
}

type StateTransition struct {
	From      string
	To        string
	Timestamp time.Time
	Duration  float64
	Metadata  map[string]any
}

type Step interface {
	ID() string
	Name() string
	Type() StepType
	Description() string
	Execute(ctx context.Context, input *StepInput) *stream.Reader[*StepOutput]
	Config() *StepConfig
}

type StepConfig struct {
	ID                    string
	Name                  string
	Description           string
	Type                  StepType
	MaxRetries            int
	Timeout               time.Duration
	SkipOnError           bool
	StrictInputValidation bool
	Metadata              map[string]any
}

type StepInput struct {
	Input               any
	PreviousStepContent any
	PreviousStepOutputs map[string]*StepOutput
	AdditionalData      map[string]any
	SessionState        map[string]any
	Images              []any
	Videos              []any
	Audio               []any
	Files               []any
	WorkflowSession     *WorkflowSession
}

type StepMetrics struct {
	ExecutionTime float64
	InputTokens   int
	OutputTokens  int
	TotalTokens   int
	RetryCount    int
	Custom        map[string]any
}

type StepOutput struct {
	StepID      string
	StepName    string
	StepType    StepType
	Content     any
	Error       error
	Metadata    map[string]any
	Metrics     *StepMetrics
	NestedSteps []*StepOutput
	StartTime   time.Time
	EndTime     time.Time
	Duration    float64
}

type StepType string

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

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

type StressTester interface {
	Test(ctx context.Context, output *StepOutput) (score float64, issues []string, err error)
}

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

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

type SwitchCase struct {
	Value       string    `json:"value"`       // 匹配值
	Agent       *AgentRef `json:"agent"`       // 分支Agent
	Name        string    `json:"name"`        // 分支名称
	Fallthrough bool      `json:"fallthrough"` // 是否继续匹配下一个case
}

type SwitchConfig struct {
	Name     string       `json:"name"`
	Variable string       `json:"variable"` // switch变量名
	Cases    []SwitchCase `json:"cases"`
	Default  *AgentRef    `json:"default,omitempty"`
}

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

type TransitionCondition func(ctx context.Context) (bool, error)

type VariableDef struct {
	Name        string `json:"name"`
	Type        string `json:"type"` // string, number, boolean, object, array
	Description string `json:"description"`
	Required    bool   `json:"required"`
	Default     any    `json:"default,omitempty"`
	Validation  string `json:"validation,omitempty"` // JSON Schema or validation rules
}

type Workflow struct {
	// 标识
	ID          string
	Name        string
	Description string

	// 步骤
	Steps []Step

	// 数据库
	DB store.Store

	// 会话
	SessionID    string
	UserID       string
	SessionState map[string]any
	CacheSession bool

	// 配置
	MaxRetries int
	Timeout    time.Duration
	RetryDelay time.Duration

	// 流式
	Stream               bool
	StreamEvents         bool
	StreamExecutorEvents bool

	// 调试
	DebugMode bool

	// 存储
	StoreEvents          bool
	StoreExecutorOutputs bool
	SkipEvents           []WorkflowEventType

	// 输入验证
	InputSchema any // Type for input validation

	// 元数据
	Metadata map[string]any

	// 历史
	AddWorkflowHistory bool
	NumHistoryRuns     int
	// contains filtered or unexported fields
}

type WorkflowAgent struct {
	ID                 string
	Name               string
	Instructions       string
	Model              string
	AddWorkflowHistory bool
	NumHistoryRuns     int
	// contains filtered or unexported fields
}

type WorkflowConfig struct {
	// 超时配置
	DefaultTimeout time.Duration `json:"default_timeout"`

	// 重试配置
	DefaultRetry *RetryDef `json:"default_retry,omitempty"`

	// 并发配置
	MaxConcurrency int `json:"max_concurrency"`

	// 监控配置
	Monitoring *MonitoringConfig `json:"monitoring,omitempty"`

	// 日志配置
	Logging *LoggingConfig `json:"logging,omitempty"`

	// 安全配置
	Security *SecurityConfig `json:"security,omitempty"`
}

type WorkflowContext struct {
	// 基本信息
	WorkflowID  string         `json:"workflow_id"`
	ExecutionID string         `json:"execution_id"`
	StartTime   time.Time      `json:"start_time"`
	Status      WorkflowStatus `json:"status"`

	// 变量存储
	Variables map[string]any `json:"variables"`
	Inputs    map[string]any `json:"inputs"`
	Outputs   map[string]any `json:"outputs"`

	// 执行状态
	CurrentNode string           `json:"current_node"`
	Completed   map[string]bool  `json:"completed"`
	Failed      map[string]error `json:"failed"`

	// 元数据
	Metadata map[string]any `json:"metadata"`

	// 上下文
	Context context.Context  `json:"-"`
	Session *session.Session `json:"-"`
}

type WorkflowDefinition struct {
	// 基本信息
	ID          string   `json:"id"`
	Name        string   `json:"name"`
	Description string   `json:"description"`
	Version     string   `json:"version"`
	Tags        []string `json:"tags"`

	// 输入输出定义
	Inputs  []VariableDef `json:"inputs"`
	Outputs []VariableDef `json:"outputs"`

	// 工作流图
	Nodes []NodeDef `json:"nodes"`
	Edges []EdgeDef `json:"edges"`

	// 执行配置
	Config *WorkflowConfig `json:"config,omitempty"`

	// 元数据
	Metadata map[string]string `json:"metadata,omitempty"`
}

type WorkflowError struct {
	NodeID    string    `json:"node_id"`
	NodeName  string    `json:"node_name"`
	Error     string    `json:"error"`
	Timestamp time.Time `json:"timestamp"`
	Retryable bool      `json:"retryable"`
}

type WorkflowEvent struct {
	Type        string         `json:"type"`
	ExecutionID string         `json:"execution_id"`
	NodeID      string         `json:"node_id"`
	Timestamp   time.Time      `json:"timestamp"`
	Data        map[string]any `json:"data"`
}

type WorkflowEventType string

type WorkflowExecution struct {
	// 基本信息
	ID         string              `json:"id"`
	WorkflowID string              `json:"workflow_id"`
	Definition *WorkflowDefinition `json:"definition"`
	Status     WorkflowStatus      `json:"status"`
	Context    *WorkflowContext    `json:"context"`

	// 执行状态
	CurrentNodes   []string               `json:"current_nodes"`
	CompletedNodes map[string]bool        `json:"completed_nodes"`
	FailedNodes    map[string]error       `json:"failed_nodes"`
	NodeResults    map[string]*NodeResult `json:"node_results"`

	// 时间信息
	StartTime    time.Time `json:"start_time"`
	EndTime      time.Time `json:"end_time"`
	LastActivity time.Time `json:"last_activity"`

	// 错误处理
	Errors   []WorkflowError `json:"errors"`
	Warnings []string        `json:"warnings"`
	// contains filtered or unexported fields
}

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

type WorkflowHistoryItem struct {
	RunID     string
	Input     any
	Output    any
	Status    string
	StartTime time.Time
	EndTime   time.Time
	Duration  float64
	Metrics   *RunMetrics
}

type WorkflowInput struct {
	Input          any
	AdditionalData map[string]any
	Images         []any
	Videos         []any
	Audio          []any
	Files          []any
	SessionID      string
	UserID         string
	SessionState   map[string]any
}

type WorkflowMetrics struct {
	TotalNodes      int           `json:"total_nodes"`
	CompletedNodes  int           `json:"completed_nodes"`
	FailedNodes     int           `json:"failed_nodes"`
	SkippedNodes    int           `json:"skipped_nodes"`
	TotalDuration   time.Duration `json:"total_duration"`
	AverageNodeTime time.Duration `json:"average_node_time"`
	MaxNodeTime     time.Duration `json:"max_node_time"`
	MinNodeTime     time.Duration `json:"min_node_time"`
}

type WorkflowOutput struct {
	RunID        string
	WorkflowID   string
	WorkflowName string
	Content      any
	Error        error
	StepOutputs  map[string]*StepOutput
	SessionID    string
	SessionState map[string]any
	Metrics      *RunMetrics
	Status       RunStatus
	StartTime    time.Time
	EndTime      time.Time
	Duration     float64
}

type WorkflowResult struct {
	ExecutionID string           `json:"execution_id"`
	WorkflowID  string           `json:"workflow_id"`
	Status      WorkflowStatus   `json:"status"`
	StartTime   time.Time        `json:"start_time"`
	EndTime     time.Time        `json:"end_time"`
	Duration    time.Duration    `json:"duration"`
	Outputs     map[string]any   `json:"outputs"`
	Errors      []WorkflowError  `json:"errors,omitempty"`
	Metrics     *WorkflowMetrics `json:"metrics,omitempty"`
	Trace       []WorkflowStep   `json:"trace,omitempty"`
}

type WorkflowRun struct {
	RunID       string
	SessionID   string
	WorkflowID  string
	Input       any
	Output      any
	StepOutputs map[string]*StepOutput
	Status      RunStatus
	Error       string
	Metrics     *RunMetrics
	StartTime   time.Time
	EndTime     time.Time
	Duration    float64
}

type WorkflowSession struct {
	ID         string
	WorkflowID string
	State      map[string]any
	History    []*WorkflowRun
	CreatedAt  time.Time
	UpdatedAt  time.Time
}

type WorkflowStatus string

type WorkflowStep struct {
	NodeID     string         `json:"node_id"`
	NodeName   string         `json:"node_name"`
	NodeType   NodeType       `json:"node_type"`
	Status     WorkflowStatus `json:"status"`
	StartTime  time.Time      `json:"start_time"`
	EndTime    time.Time      `json:"end_time"`
	Duration   time.Duration  `json:"duration"`
	Inputs     map[string]any `json:"inputs"`
	Outputs    map[string]any `json:"outputs"`
	Error      string         `json:"error,omitempty"`
	RetryCount int            `json:"retry_count"`
	Metadata   map[string]any `json:"metadata"`
}

type WorkflowToolFunc func(ctx context.Context, query string) (any, error)

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