template

type CreatePipelineRequest struct {
	// 所属域
	Domain string `json:"domain" gorm:"column:domain" validate:"required"`
	// 所属空间
	Namespace string `json:"namespace" gorm:"column:namespace" validate:"required"`
	// 创建人
	CreateBy string `json:"create_by" gorm:"column:create_by"`
	// 定义
	PipelineSpec
}

type DeletePipelineRequest struct {
	DescribePipelineRequest
}

type DescribePipelineRequest struct {
	PipelineId string `json:"pipeline_id"`
}

type Pipeline struct {
	// 对象Id
	Id string `json:"id" gorm:"column:id;primaryKey"`
	// 创建时间
	CreateAt time.Time `json:"create_at" gorm:"column:create_at"`
	// 更新时间
	UpdateAt *time.Time `json:"update_at" gorm:"column:update_at"`
	// 更新人
	UpdateBy string `json:"update_by" gorm:"column:update_by;type:varchar(60)"`

	// Pipeline信息
	CreatePipelineRequest
}

type PipelineSpec struct {
	// 名称
	Name string `json:"name" gorm:"column:name" validate:"required"`
	// 描述
	Description string `json:"description"  gorm:"column:description"`
	// 图标
	Logo string `json:"logo" gorm:"column:logo"`
	// 是否需要审核才能执行, 默认不需要审核
	RequiredApproval *bool `json:"required_approval" gorm:"required_approval"`
	// 是否允许并行允许, 默认为false, 同一时间只能有一个运行中的任务
	IsParallel *bool `json:"is_parallel" gorm:"column:is_parallel"`
	// 是否是模版, 用于快速继承模版参数进行修改, 模版不能用于执行
	IsTemplate *bool `json:"is_template" gorm:"column:is_template"`
	// 运行时 全局参数, 会传递给每个Task
	RunParams []*job.RunParam `json:"run_params" gorm:"column:run_params;serializer:json;type:json"`
	// 任务列表
	Tasks []*task.Task `json:"tasks" gorm:"column:tasks;serializer:json;type:json"`
	// 下一个需要运行的Pipeline, 多个Pipeline编排时指定先后顺序
	NextPipeline string `json:"next_pipeline" gorm:"next_pipeline"`
	// 额外的其他属性
	Extras map[string]string `json:"extras" form:"extras" gorm:"column:extras;type:json;serializer:json;"`
	// 标签
	Label map[string]string `json:"label" gorm:"column:label;type:json;serializer:json;"`
}

type QueryPipelineRequest struct {
	request.PageRequest
}

type Service interface {
	// 创建流水线
	CreatePipeline(context.Context, *CreatePipelineRequest) (*Pipeline, error)
	// 查询流水线
	QueryPipeline(context.Context, *QueryPipelineRequest) (*types.Set[*Pipeline], error)
	// 获取流水线
	DescribePipeline(context.Context, *DescribePipelineRequest) (*Pipeline, error)

	// 删除流水线
	DeletePipeline(context.Context, *DeletePipelineRequest) (*Pipeline, error)
}