Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ValidateWorkflowForPipeline = func(ppl models.Pipeline) error { wfs, err := schema.ParseWorkflowSource([]byte(ppl.PipelineYaml)) if err != nil { logger.Logger().Errorf("get WorkflowSource by yaml failed. yaml: %s \n, err:%v", ppl.PipelineYaml, err) return err } param := map[string]interface{}{} extra := map[string]string{ pplcommon.WfExtraInfoKeyUserName: ppl.UserName, pplcommon.WfExtraInfoKeyFsName: ppl.FsName, pplcommon.WfExtraInfoKeyFsID: ppl.FsID, } wfCbs := pipeline.WorkflowCallbacks{ UpdateRunCb: func(string, interface{}) bool { return true }, LogCacheCb: run.LogCacheFunc, ListCacheCb: run.ListCacheFunc, } wfPtr, err := pipeline.NewWorkflow(wfs, "validatePipeline", "", param, extra, wfCbs) if err != nil { logger.Logger().Errorf("NewWorkflow for pipeline[%s] failed. err:%v", ppl.Name, err) return err } if wfPtr == nil { err := fmt.Errorf("NewWorkflow ptr for pipeline[%s] is nil", ppl.Name) logger.Logger().Errorln(err.Error()) return err } return nil }
Functions ¶
func DeletePipeline ¶
func DeletePipeline(ctx *logger.RequestContext, id string) error
func GetPipelineByID ¶
Types ¶
type CreatePipelineRequest ¶
type CreatePipelineResponse ¶
func CreatePipeline ¶
func CreatePipeline(ctx *logger.RequestContext, request CreatePipelineRequest) (CreatePipelineResponse, error)
type ListPipelineResponse ¶
type ListPipelineResponse struct { common.MarkerInfo PipelineList []models.Pipeline `json:"pipelineList"` }
func ListPipeline ¶
func ListPipeline(ctx *logger.RequestContext, marker string, maxKeys int, userFilter, fsFilter, nameFilter []string) (ListPipelineResponse, error)
Click to show internal directories.
Click to hide internal directories.