Versions in this module Expand all Collapse all v0 v0.0.10 Apr 10, 2026 v0.0.9 Mar 17, 2026 Changes in this version + const APP_NAME + type CreatePipelineRequest struct + CreateBy string + Domain string + Namespace string + func NewCreatePipelineRequest() *CreatePipelineRequest + func (r *CreatePipelineRequest) AddTask(tasks ...*task.Task) *CreatePipelineRequest + func (r *CreatePipelineRequest) SetDescription(description string) *CreatePipelineRequest + func (r *CreatePipelineRequest) SetIsParallel(isParallel bool) *CreatePipelineRequest + func (r *CreatePipelineRequest) SetIsTemplate(isTemplate bool) *CreatePipelineRequest + func (r *CreatePipelineRequest) SetLabel(key, value string) *CreatePipelineRequest + func (r *CreatePipelineRequest) SetName(name string) *CreatePipelineRequest + func (r *CreatePipelineRequest) SetNamespace(namespace string) *CreatePipelineRequest + func (r *CreatePipelineRequest) SetRequiredApproval(requiredApproval bool) *CreatePipelineRequest + func (r *CreatePipelineRequest) SetRunParam(param *job.RunParam) *CreatePipelineRequest + func (r *CreatePipelineRequest) Validate() error + type DeletePipelineRequest struct + type DescribePipelineRequest struct + PipelineId string + func NewDescribePipelineRequest(pipelineId string) *DescribePipelineRequest + type Pipeline struct + CreateAt time.Time + Id string + UpdateAt *time.Time + UpdateBy string + func NewPipeline(spec CreatePipelineRequest) *Pipeline + func (r *Pipeline) String() string + func (r *Pipeline) TableName() string + type PipelineSpec struct + Description string + Extras map[string]string + IsParallel *bool + IsTemplate *bool + Label map[string]string + Logo string + Name string + NextPipeline string + RequiredApproval *bool + RunParams []*job.RunParam + Tasks []*task.Task + func (r *PipelineSpec) AddTask(tasks ...*task.Task) + type QueryPipelineRequest struct + func NewQueryPipelineRequest() *QueryPipelineRequest + type Service interface + CreatePipeline func(context.Context, *CreatePipelineRequest) (*Pipeline, error) + DeletePipeline func(context.Context, *DeletePipelineRequest) (*Pipeline, error) + DescribePipeline func(context.Context, *DescribePipelineRequest) (*Pipeline, error) + QueryPipeline func(context.Context, *QueryPipelineRequest) (*types.Set[*Pipeline], error) + func GetService() Service
Go to main page