Versions in this module Expand all Collapse all v0 v0.14.2 Jun 1, 2022 Changes in this version + var GetJobFunc func(runID string, stepName string) (schema.JobView, error) = GetJobByRun + var ListCacheFunc func(firstFp, fsID, step, source string) ([]models.RunCache, error) = ListCacheByFirstFp + var LogArtifactFunc func(req schema.LogRunArtifactRequest) error = LogArtifactEvent + var LogCacheFunc func(req schema.LogRunCacheRequest) (string, error) = LogCache + var UpdateRunFunc func(id string, event interface{}) bool = UpdateRunByWfEvent + func DeleteArtifactEvent(ctx *logger.RequestContext, username, fsname, runID, artifactPath string) error + func DeleteRun(ctx *logger.RequestContext, id string, request *DeleteRunRequest) error + func DeleteRunCache(ctx *logger.RequestContext, id string) error + func GetJobByRun(runID string, stepName string) (schema.JobView, error) + func GetRunByID(ctx *logger.RequestContext, runID string) (models.Run, error) + func GetRunCache(ctx *logger.RequestContext, id string) (models.RunCache, error) + func InitAndResumeRuns() (*handler.ImageHandler, error) + func ListCacheByFirstFp(firstFp, fsID, step, source string) ([]models.RunCache, error) + func LogArtifactEvent(req schema.LogRunArtifactRequest) error + func LogCache(req schema.LogRunCacheRequest) (string, error) + func RetryRun(ctx *logger.RequestContext, runID string) error + func StopRun(ctx *logger.RequestContext, runID string, request UpdateRunRequest) error + func UpdateRunByWfEvent(id string, event interface{}) bool + type ArtifactsJson struct + Input map[string]string + Output []string + type CreateRunByJsonRequest struct + Cache schema.Cache + Description string + Disabled string + DockerEnv string + EntryPoints map[string]*RunStep + Env map[string]string + FailureOptions schema.FailureOptions + Flavour string + FsName string + JobType string + Name string + Parallelism int + PostProcess map[string]*RunStep + Queue string + UserName string + type CreateRunRequest struct + Description string + Disabled string + DockerEnv string + Entry string + FsName string + Name string + Parameters map[string]interface{} + PipelineID string + RunYamlPath string + RunYamlRaw string + UserName string + type CreateRunResponse struct + RunID string + func CreateRun(userName string, request *CreateRunRequest) (CreateRunResponse, error) + func CreateRunByJson(userName string, request *CreateRunByJsonRequest, ...) (CreateRunResponse, error) + func ValidateAndStartRun(run models.Run, req interface{}) (CreateRunResponse, error) + type DeleteRunRequest struct + CheckCache bool + type ListArtifactEventResponse struct + ArtifactEventList []models.ArtifactEvent + func ListArtifactEvent(ctx *logger.RequestContext, marker string, maxKeys int, ...) (ListArtifactEventResponse, error) + type ListRunCacheResponse struct + RunCacheList []models.RunCache + func ListRunCache(ctx *logger.RequestContext, marker string, maxKeys int, ...) (ListRunCacheResponse, error) + type ListRunResponse struct + RunList []RunBrief + func ListRun(ctx *logger.RequestContext, marker string, maxKeys int, ...) (ListRunResponse, error) + type RunBrief struct + ActivateTime string + CreateTime string + FsName string + ID string + Message string + Name string + Source string + Status string + UserName string + type RunStep struct + Artifacts ArtifactsJson + Cache schema.Cache + Command string + Deps string + DockerEnv string + Env map[string]string + Flavour string + JobType string + Parameters map[string]interface{} + Queue string + type UpdateRunRequest struct + StopForce bool