scheduler

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

type JobExecution struct {
	JobID     string
	StartTime time.Time
	EndTime   *time.Time
	Success   bool
	Error     error
	Attempt   int
}

type JobHandler func(ctx context.Context, jobID string) error

type JobSpec struct {
	ID         string
	Name       string
	Schedule   string
	Timezone   *time.Location
	Enabled    bool
	LastRun    *time.Time
	NextRun    *time.Time
	Handler    JobHandler
	MaxRetries int
	RetryDelay time.Duration
	// contains filtered or unexported fields
}

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

type MCPToolCall struct {
	Tool       string                 `json:"tool"`
	Parameters map[string]interface{} `json:"parameters"`
}

type MCPToolResponse struct {
	Success bool                   `json:"success"`
	Result  map[string]interface{} `json:"result,omitempty"`
	Error   string                 `json:"error,omitempty"`
}

type MountInfo struct {
	WorkflowName string    `json:"workflowName"`
	ExecutionID  string    `json:"executionID"`
	PVCName      string    `json:"pvcName"`
	MountPath    string    `json:"mountPath"`
	MountedAt    time.Time `json:"mountedAt"`
	LastAccess   time.Time `json:"lastAccess"`
	AccessCount  int64     `json:"accessCount"`
}

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

type StepContext struct {
	WorkflowName      string
	WorkflowNamespace string
	StepName          string
	Attempt           int
	PreviousOutputs   map[string]interface{}
}

type StepExecution struct {
	Name       string
	Tool       string
	Parameters map[string]interface{}
	StartTime  time.Time
	EndTime    *time.Time
	Status     StepExecutionStatus
	Output     interface{}
	Error      string
	Attempts   int
	Duration   time.Duration
	Condition  string
	Skipped    bool
	SkipReason string
}

type StepExecutionContext struct {
	StepName string
}

type StepExecutionResult struct {
	Status   string
	Message  string
	Success  bool
	Output   interface{}
	Duration time.Duration
	Error    error
}

type StepExecutionStatus string

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

type TemplateParameter struct {
	Name        string      `json:"name"`
	Description string      `json:"description"`
	Type        string      `json:"type"`
	Required    bool        `json:"required"`
	Default     interface{} `json:"default,omitempty"`
	Options     []string    `json:"options,omitempty"`
	Validation  string      `json:"validation,omitempty"`
}

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

type ToolExecutionRequest struct {
	Tool       string                 `json:"tool"`
	Parameters map[string]interface{} `json:"parameters"`
	Timeout    time.Duration          `json:"timeout"`
}

type ToolExecutionResult struct {
	Success  bool                   `json:"success"`
	Output   map[string]interface{} `json:"output,omitempty"`
	Error    string                 `json:"error,omitempty"`
	Duration time.Duration          `json:"duration"`
}

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

type ToolExecutorInterface interface {
	ExecuteTool(ctx context.Context, toolName string, args map[string]interface{}) (interface{}, error)
	ExecuteStepWithContext(ctx context.Context, stepContext *StepExecutionContext, toolName string, args map[string]interface{}) (*StepExecutionResult, error)
}

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

type WorkflowExecution struct {
	ID                string
	WorkflowName      string
	WorkflowNamespace string
	StartTime         time.Time
	EndTime           *time.Time
	Status            WorkflowExecutionStatus
	Steps             []StepExecution
	Error             string
	Context           *WorkflowExecutionContext
}

type WorkflowExecutionContext struct {
	WorkflowDefinition *crd.WorkflowDefinition
	ExecutionTimeout   time.Duration
	StepOutputs        map[string]interface{}
	FailureThreshold   int
	FailureCount       int
	ContinueOnFailure  bool
}

type WorkflowExecutionDBRecord struct {
	ID           uuid.UUID              `json:"id"`
	WorkflowID   uuid.UUID              `json:"workflow_id"`
	RunID        string                 `json:"run_id"`
	Status       string                 `json:"status"`
	TriggerType  string                 `json:"trigger_type"`
	StartedAt    time.Time              `json:"started_at"`
	CompletedAt  *time.Time             `json:"completed_at"`
	ErrorMessage *string                `json:"error_message"`
	Result       map[string]interface{} `json:"result"`
}

type WorkflowExecutionRecord struct {
	ID                string     `json:"id"`
	WorkflowName      string     `json:"workflowName"`
	WorkflowNamespace string     `json:"workflowNamespace"`
	StartTime         time.Time  `json:"startTime"`
	EndTime           *time.Time `json:"endTime,omitempty"`
	Status            string     `json:"status"`
	Steps             string     `json:"steps"` // JSON-encoded steps
	Error             string     `json:"error,omitempty"`
	CreatedAt         time.Time  `json:"createdAt"`
	UpdatedAt         time.Time  `json:"updatedAt"`
}

type WorkflowExecutionStatus string

type WorkflowRecord struct {
	ID                uuid.UUID                  `json:"id"`
	Name              string                     `json:"name"`
	Description       string                     `json:"description"`
	Schedule          string                     `json:"schedule"`
	Timezone          string                     `json:"timezone"`
	Enabled           bool                       `json:"enabled"`
	Status            string                     `json:"status"` // active, disabled, deleted
	ConcurrencyPolicy string                     `json:"concurrency_policy"`
	TimeoutSeconds    *int                       `json:"timeout_seconds"`
	Steps             []WorkflowStepRecord       `json:"steps"`
	RetryPolicy       *WorkflowRetryPolicyRecord `json:"retry_policy"`
	CreatedAt         time.Time                  `json:"created_at"`
	UpdatedAt         time.Time                  `json:"updated_at"`
}

type WorkflowRetryPolicyRecord struct {
	WorkflowID           uuid.UUID `json:"workflow_id"`
	MaxRetries           int       `json:"max_retries"`
	RetryDelaySeconds    int       `json:"retry_delay_seconds"`
	BackoffStrategy      string    `json:"backoff_strategy"`
	MaxRetryDelaySeconds int       `json:"max_retry_delay_seconds"`
	BackoffMultiplier    float64   `json:"backoff_multiplier"`
}

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

type WorkflowStepRecord struct {
	ID              uuid.UUID              `json:"id"`
	WorkflowID      uuid.UUID              `json:"workflow_id"`
	Name            string                 `json:"name"`
	StepOrder       int                    `json:"step_order"`
	Tool            string                 `json:"tool"`
	Parameters      map[string]interface{} `json:"parameters"`
	ConditionExpr   string                 `json:"condition_expr"`
	ContinueOnError bool                   `json:"continue_on_error"`
	TimeoutSeconds  *int                   `json:"timeout_seconds"`
	DependsOn       []string               `json:"depends_on"`
	CreatedAt       time.Time              `json:"created_at"`
}

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

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

type WorkflowTemplate struct {
	Name        string                 `json:"name"`
	Description string                 `json:"description"`
	Category    string                 `json:"category"`
	Tags        []string               `json:"tags"`
	Parameters  []TemplateParameter    `json:"parameters"`
	Spec        crd.WorkflowDefinition `json:"spec"`
}

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

type WorkspaceCleanupStats struct {
	TotalWorkspaces   int32     `json:"totalWorkspaces"`
	ExpiredWorkspaces int32     `json:"expiredWorkspaces"`
	DeletedCount      int32     `json:"deletedCount"`
	ErrorCount        int32     `json:"errorCount"`
	LastCleanupTime   time.Time `json:"lastCleanupTime"`
	NextCleanupTime   time.Time `json:"nextCleanupTime"`
}