workflows

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

type RunRepository interface {
	CreateWorkflowRun(WorkflowRun) (WorkflowRun, error)
	UpdateWorkflowRun(WorkflowRun) (WorkflowRun, error)
	GetWorkflowRun(string) (WorkflowRun, error)
}

type RunStatus string

type Step struct {
	Name        string     `json:"name"`
	Status      RunStatus  `json:"status"`
	Error       string     `json:"error,omitempty"`
	Output      string     `json:"output,omitempty"`
	CompletedAt *time.Time `json:"completed_at,omitempty"`
}

type StepExecutor func(run *WorkflowRun, stepName string, db *sql.DB) error

type Workflow struct {
	Type  WorkflowType
	Name  string
	Steps []string
}

type WorkflowRun struct {
	ID           string
	WorkflowType WorkflowType
	Status       RunStatus
	Steps        []Step
	StartedAt    time.Time
	FinishedAt   time.Time
}

type WorkflowType string