workflow

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

type BaseStepOption func(*BaseStep)

type ConditionFunc func(ctx context.Context, input StepInput) (string, error)

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

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

type ExecutionContext struct {
	// Variables 变量
	Variables map[string]any `json:"variables,omitempty"`

	// CurrentStepID 当前步骤 ID
	CurrentStepID string `json:"current_step_id,omitempty"`

	// CompletedSteps 已完成的步骤
	CompletedSteps []string `json:"completed_steps,omitempty"`

	// PendingSteps 待执行的步骤
	PendingSteps []string `json:"pending_steps,omitempty"`

	// SkippedSteps 跳过的步骤
	SkippedSteps []string `json:"skipped_steps,omitempty"`

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

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

type ExecutionSnapshot struct {
	// ExecutionID 执行实例 ID
	ExecutionID string `json:"execution_id"`

	// WorkflowID 工作流 ID
	WorkflowID string `json:"workflow_id"`

	// Status 状态
	Status WorkflowStatus `json:"status"`

	// Context 上下文
	Context *ExecutionContext `json:"context"`

	// StepResults 步骤结果
	StepResults map[string]*StepResult `json:"step_results"`

	// Input 输入
	Input json.RawMessage `json:"input"`

	// CreatedAt 创建时间
	CreatedAt time.Time `json:"created_at"`
}

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

type ExecutorConfig struct {
	// DefaultTimeout 默认超时时间
	DefaultTimeout time.Duration

	// MaxConcurrentExecutions 最大并发执行数
	MaxConcurrentExecutions int

	// EnablePersistence 启用持久化
	EnablePersistence bool
}

type ExecutorOption func(*Executor)

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

type LoopStepOption func(*LoopStep)

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

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

type ParallelStepOption func(*ParallelStep)

type RetryPolicy struct {
	// MaxRetries 最大重试次数
	MaxRetries int `json:"max_retries"`

	// InitialInterval 初始间隔
	InitialInterval time.Duration `json:"initial_interval"`

	// MaxInterval 最大间隔
	MaxInterval time.Duration `json:"max_interval"`

	// Multiplier 间隔倍数
	Multiplier float64 `json:"multiplier"`

	// RetryableErrors 可重试的错误类型
	RetryableErrors []string `json:"retryable_errors,omitempty"`
}

type Step interface {
	// ID 返回步骤 ID
	ID() string

	// Name 返回步骤名称
	Name() string

	// Type 返回步骤类型
	Type() StepType

	// Execute 执行步骤
	Execute(ctx context.Context, input StepInput) (*StepOutput, error)

	// Validate 验证步骤配置
	Validate() error
}

type StepDefinition struct {
	// ID 步骤 ID
	ID string `json:"id"`

	// Name 步骤名称
	Name string `json:"name"`

	// Type 步骤类型
	Type StepType `json:"type"`

	// Description 描述
	Description string `json:"description,omitempty"`

	// Config 配置
	Config map[string]any `json:"config,omitempty"`

	// Dependencies 依赖的步骤 ID
	Dependencies []string `json:"dependencies,omitempty"`
}

type StepFunc func(ctx context.Context, input StepInput) (*StepOutput, error)

type StepInput struct {
	// Data 输入数据
	Data any

	// Variables 上下文变量
	Variables map[string]any

	// PreviousOutputs 前置步骤的输出
	PreviousOutputs map[string]any

	// Metadata 元数据
	Metadata map[string]any
}

type StepOutput struct {
	// Data 输出数据
	Data any

	// Variables 更新的变量
	Variables map[string]any

	// Metadata 元数据
	Metadata map[string]any

	// NextStepID 下一步骤 ID（用于条件步骤）
	NextStepID string
}

type StepResult struct {
	// StepID 步骤 ID
	StepID string `json:"step_id"`

	// Status 状态
	Status WorkflowStatus `json:"status"`

	// Output 输出数据
	Output any `json:"output,omitempty"`

	// Error 错误信息
	Error string `json:"error,omitempty"`

	// StartedAt 开始时间
	StartedAt time.Time `json:"started_at"`

	// CompletedAt 完成时间
	CompletedAt *time.Time `json:"completed_at,omitempty"`

	// Duration 执行时长
	Duration time.Duration `json:"duration,omitempty"`

	// RetryCount 重试次数
	RetryCount int `json:"retry_count,omitempty"`
}

type StepType string

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

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

type Workflow struct {
	// ID 唯一标识符
	ID string `json:"id"`

	// Name 工作流名称
	Name string `json:"name"`

	// Description 描述
	Description string `json:"description,omitempty"`

	// Version 版本
	Version string `json:"version,omitempty"`

	// Steps 步骤列表
	Steps []Step `json:"-"`

	// StepDefs 步骤定义（用于序列化）
	StepDefs []StepDefinition `json:"steps"`

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

	// Timeout 总超时时间
	Timeout time.Duration `json:"timeout,omitempty"`

	// RetryPolicy 默认重试策略
	RetryPolicy *RetryPolicy `json:"retry_policy,omitempty"`

	// CreatedAt 创建时间
	CreatedAt time.Time `json:"created_at"`
}

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

type WorkflowEvent struct {
	// Type 事件类型
	Type WorkflowEventType `json:"type"`

	// ExecutionID 执行实例 ID
	ExecutionID string `json:"execution_id"`

	// StepID 步骤 ID（如果适用）
	StepID string `json:"step_id,omitempty"`

	// Status 状态
	Status WorkflowStatus `json:"status"`

	// Data 事件数据
	Data any `json:"data,omitempty"`

	// Error 错误信息
	Error string `json:"error,omitempty"`

	// Timestamp 时间戳
	Timestamp time.Time `json:"timestamp"`
}

type WorkflowEventHandler func(event *WorkflowEvent)

type WorkflowEventType string

type WorkflowExecution struct {
	// ID 执行实例 ID
	ID string `json:"id"`

	// WorkflowID 工作流 ID
	WorkflowID string `json:"workflow_id"`

	// Status 状态
	Status WorkflowStatus `json:"status"`

	// Input 输入数据
	Input json.RawMessage `json:"input,omitempty"`

	// Output 输出数据
	Output json.RawMessage `json:"output,omitempty"`

	// Error 错误信息
	Error string `json:"error,omitempty"`

	// Context 执行上下文
	Context *ExecutionContext `json:"context"`

	// StepResults 步骤执行结果
	StepResults map[string]*StepResult `json:"step_results"`

	// StartedAt 开始时间
	StartedAt time.Time `json:"started_at"`

	// CompletedAt 完成时间
	CompletedAt *time.Time `json:"completed_at,omitempty"`

	// PausedAt 暂停时间
	PausedAt *time.Time `json:"paused_at,omitempty"`

	// Duration 执行时长
	Duration time.Duration `json:"duration,omitempty"`
}

type WorkflowHooks struct {
	// OnStart 工作流开始时触发
	OnStart func(ctx context.Context, wf *Workflow, input WorkflowInput) error

	// OnComplete 工作流完成时触发
	OnComplete func(ctx context.Context, wf *Workflow, output *WorkflowOutput) error

	// OnError 工作流出错时触发
	OnError func(ctx context.Context, wf *Workflow, err error) error

	// OnStepStart 步骤开始时触发
	OnStepStart func(ctx context.Context, step Step, input any) error

	// OnStepComplete 步骤完成时触发
	OnStepComplete func(ctx context.Context, step Step, output any) error

	// OnStepError 步骤出错时触发
	OnStepError func(ctx context.Context, step Step, err error) error
}

type WorkflowInput struct {
	// Data 输入数据
	Data any `json:"data"`

	// Variables 初始变量
	Variables map[string]any `json:"variables,omitempty"`

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

type WorkflowOutput struct {
	// Data 输出数据
	Data any `json:"data"`

	// Variables 最终变量
	Variables map[string]any `json:"variables,omitempty"`

	// StepOutputs 各步骤输出
	StepOutputs map[string]any `json:"step_outputs,omitempty"`

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

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

type WorkflowRunner interface {
	// Run 运行工作流
	Run(ctx context.Context, wf *Workflow, input WorkflowInput) (*WorkflowOutput, error)

	// RunAsync 异步运行工作流
	RunAsync(ctx context.Context, wf *Workflow, input WorkflowInput) (string, error)

	// Pause 暂停执行
	Pause(ctx context.Context, executionID string) error

	// Resume 恢复执行
	Resume(ctx context.Context, executionID string) error

	// Cancel 取消执行
	Cancel(ctx context.Context, executionID string) error

	// GetExecution 获取执行实例
	GetExecution(ctx context.Context, executionID string) (*WorkflowExecution, error)

	// WaitForCompletion 等待执行完成
	WaitForCompletion(ctx context.Context, executionID string, timeout time.Duration) (*WorkflowExecution, error)
}

type WorkflowStatus string

type WorkflowStore interface {
	// SaveWorkflow 保存工作流定义
	SaveWorkflow(ctx context.Context, wf *Workflow) error

	// GetWorkflow 获取工作流定义
	GetWorkflow(ctx context.Context, id string) (*Workflow, error)

	// ListWorkflows 列出工作流定义
	ListWorkflows(ctx context.Context, limit int) ([]*Workflow, error)

	// DeleteWorkflow 删除工作流定义
	DeleteWorkflow(ctx context.Context, id string) error

	// SaveExecution 保存执行实例
	SaveExecution(ctx context.Context, execution *WorkflowExecution) error

	// GetExecution 获取执行实例
	GetExecution(ctx context.Context, id string) (*WorkflowExecution, error)

	// ListExecutions 列出执行实例
	ListExecutions(ctx context.Context, workflowID string, status WorkflowStatus, limit int) ([]*WorkflowExecution, error)

	// DeleteExecution 删除执行实例
	DeleteExecution(ctx context.Context, id string) error

	// UpdateExecutionStatus 更新执行状态
	UpdateExecutionStatus(ctx context.Context, id string, status WorkflowStatus, errMsg string) error

	// GetPendingExecutions 获取待恢复的执行实例
	GetPendingExecutions(ctx context.Context, limit int) ([]*WorkflowExecution, error)
}