Documentation ¶
Index ¶
- Variables
- func CancelPipeline(pipelineId uint64) errors.Error
- func CancelTask(taskId uint64) errors.Error
- func CreateBlueprint(blueprint *models.Blueprint) errors.Error
- func CreateDbBlueprint(dbBlueprint *models.DbBlueprint) errors.Error
- func CreateDbPipeline(newPipeline *models.NewPipeline) (*models.DbPipeline, errors.Error)
- func CreatePipeline(newPipeline *models.NewPipeline) (*models.Pipeline, errors.Error)
- func CreateTask(newTask *models.NewTask) (*models.Task, errors.Error)
- func DeleteBlueprint(id uint64) errors.Error
- func DeleteDbBlueprint(id uint64) errors.Error
- func ExecuteMigration() errors.Error
- func FormatPipelinePlans(beforePlanJson json.RawMessage, mainPlan core.PipelinePlan, ...) (core.PipelinePlan, errors.Error)
- func GeneratePlanJson(settings json.RawMessage) (json.RawMessage, errors.Error)
- func GeneratePlanJsonV100(settings *models.BlueprintSettings) (core.PipelinePlan, errors.Error)
- func GetBlueprint(blueprintId uint64) (*models.Blueprint, errors.Error)
- func GetBlueprints(query *BlueprintQuery) ([]*models.Blueprint, int64, errors.Error)
- func GetDbBlueprint(dbBlueprintId uint64) (*models.DbBlueprint, errors.Error)
- func GetDbBlueprints(query *BlueprintQuery) ([]*models.DbBlueprint, int64, errors.Error)
- func GetDbPipeline(pipelineId uint64) (*models.DbPipeline, errors.Error)
- func GetDbPipelines(query *PipelineQuery) ([]*models.DbPipeline, int64, errors.Error)
- func GetPipeline(pipelineId uint64) (*models.Pipeline, errors.Error)
- func GetPipelineLogsArchivePath(pipeline *models.Pipeline) (string, errors.Error)
- func GetPipelines(query *PipelineQuery) ([]*models.Pipeline, int64, errors.Error)
- func GetPluginsApiResources() (map[string]map[string]map[string]core.ApiResourceHandler, errors.Error)
- func GetRepos() ([]*code.Repo, int64, errors.Error)
- func GetTask(taskId uint64) (*models.Task, errors.Error)
- func GetTasks(query *TaskQuery) ([]models.Task, int64, errors.Error)
- func Init()
- func InsertRow(table string, rows []map[string]interface{}) (int64, errors.Error)
- func MergePipelinePlans(plans ...core.PipelinePlan) core.PipelinePlan
- func MigrationRequireConfirmation() bool
- func NotifyExternal(pipelineId uint64) errors.Error
- func PatchBlueprint(id uint64, body map[string]interface{}) (*models.Blueprint, errors.Error)
- func ReloadBlueprints(c *cron.Cron) errors.Error
- func RunPipelineInQueue(pipelineMaxParallel int64)
- func TriggerBlueprint(id uint64) (*models.Pipeline, errors.Error)
- type BlueprintQuery
- type NotificationService
- type PipelineNotification
- type PipelineQuery
- type RunningTask
- func (rt *RunningTask) Add(taskId uint64, cancel context.CancelFunc) errors.Error
- func (rt *RunningTask) FillProgressDetailToTasks(tasks []models.Task)
- func (rt *RunningTask) GetProgressDetail(taskId uint64) *models.TaskProgressDetail
- func (rt *RunningTask) Remove(taskId uint64) (context.CancelFunc, errors.Error)
- type RunningTaskData
- type TaskQuery
Constants ¶
This section is empty.
Variables ¶
var ErrBlueprintRunning = errors.Default.New("the blueprint is running")
ErrBlueprintRunning indicates there is a running pipeline with the specified blueprint_id
Functions ¶
func CreateBlueprint ¶
CreateBlueprint accepts a Blueprint instance and insert it to database
func CreateDbBlueprint ¶ added in v0.14.0
func CreateDbBlueprint(dbBlueprint *models.DbBlueprint) errors.Error
CreateDbBlueprint accepts a Blueprint instance and insert it to database
func CreateDbPipeline ¶ added in v0.14.0
func CreateDbPipeline(newPipeline *models.NewPipeline) (*models.DbPipeline, errors.Error)
CreateDbPipeline returns a NewPipeline
func CreatePipeline ¶
CreatePipeline and return the model
func CreateTask ¶
CreateTask FIXME ...
func DeleteDbBlueprint ¶ added in v0.14.0
DeleteDbBlueprint deletes blueprint by id
func ExecuteMigration ¶ added in v0.12.0
ExecuteMigration executes all pending migration scripts and initialize services module
func FormatPipelinePlans ¶ added in v0.13.0
func FormatPipelinePlans(beforePlanJson json.RawMessage, mainPlan core.PipelinePlan, afterPlanJson json.RawMessage) (core.PipelinePlan, errors.Error)
FormatPipelinePlans merges multiple pipelines and append before and after pipeline
func GeneratePlanJson ¶ added in v0.12.0
func GeneratePlanJson(settings json.RawMessage) (json.RawMessage, errors.Error)
GeneratePlanJson generates pipeline plan by version
func GeneratePlanJsonV100 ¶ added in v0.12.0
func GeneratePlanJsonV100(settings *models.BlueprintSettings) (core.PipelinePlan, errors.Error)
GeneratePlanJsonV100 generates pipeline plan according v1.0.0 definition
func GetBlueprint ¶
GetBlueprint returns the detail of a given Blueprint ID
func GetBlueprints ¶
GetBlueprints returns a paginated list of Blueprints based on `query`
func GetDbBlueprint ¶ added in v0.14.0
func GetDbBlueprint(dbBlueprintId uint64) (*models.DbBlueprint, errors.Error)
GetDbBlueprint returns the detail of a given Blueprint ID
func GetDbBlueprints ¶ added in v0.14.0
func GetDbBlueprints(query *BlueprintQuery) ([]*models.DbBlueprint, int64, errors.Error)
GetDbBlueprints returns a paginated list of Blueprints based on `query`
func GetDbPipeline ¶ added in v0.14.0
func GetDbPipeline(pipelineId uint64) (*models.DbPipeline, errors.Error)
GetDbPipeline by id
func GetDbPipelines ¶ added in v0.14.0
func GetDbPipelines(query *PipelineQuery) ([]*models.DbPipeline, int64, errors.Error)
GetDbPipelines by query
func GetPipeline ¶
GetPipeline by id
func GetPipelineLogsArchivePath ¶ added in v0.13.0
GetPipelineLogsArchivePath creates an archive for the logs of this pipeline and returns its file path
func GetPipelines ¶
GetPipelines by query
func GetPluginsApiResources ¶
func GetPluginsApiResources() (map[string]map[string]map[string]core.ApiResourceHandler, errors.Error)
GetPluginsApiResources return value
{ "jira": { "connections": { "POST": *ApiResourceHandler } } }
GetPluginsApiResources returns all APIs of all plugins
func MergePipelinePlans ¶ added in v0.12.0
func MergePipelinePlans(plans ...core.PipelinePlan) core.PipelinePlan
MergePipelinePlans merges multiple pipelines into one unified pipeline
func MigrationRequireConfirmation ¶ added in v0.12.0
func MigrationRequireConfirmation() bool
MigrationRequireConfirmation returns if there were migration scripts waiting to be executed
func PatchBlueprint ¶ added in v0.12.0
PatchBlueprint FIXME ...
func RunPipelineInQueue ¶ added in v0.12.0
func RunPipelineInQueue(pipelineMaxParallel int64)
RunPipelineInQueue query pipeline from db and run it in a queue
Types ¶
type BlueprintQuery ¶
type BlueprintQuery struct { Enable *bool `form:"enable,omitempty"` Page int `form:"page"` PageSize int `form:"pageSize"` }
BlueprintQuery FIXME ...
type NotificationService ¶
NotificationService FIXME ...
func NewNotificationService ¶
func NewNotificationService(endpoint, secret string) *NotificationService
NewNotificationService FIXME ...
func (*NotificationService) PipelineStatusChanged ¶
func (n *NotificationService) PipelineStatusChanged(params PipelineNotification) errors.Error
PipelineStatusChanged FIXME ...
type PipelineNotification ¶
type PipelineNotification struct { PipelineID uint64 CreatedAt time.Time UpdatedAt time.Time BeganAt *time.Time FinishedAt *time.Time Status string }
PipelineNotification FIXME ...
type PipelineQuery ¶
type PipelineQuery struct { Status string `form:"status"` Pending int `form:"pending"` Page int `form:"page"` PageSize int `form:"pageSize"` BlueprintId uint64 `uri:"blueprintId" form:"blueprint_id"` }
PipelineQuery FIXME ...
type RunningTask ¶
type RunningTask struct {
// contains filtered or unexported fields
}
RunningTask FIXME ...
func (*RunningTask) Add ¶
func (rt *RunningTask) Add(taskId uint64, cancel context.CancelFunc) errors.Error
Add FIXME ...
func (*RunningTask) FillProgressDetailToTasks ¶
func (rt *RunningTask) FillProgressDetailToTasks(tasks []models.Task)
FillProgressDetailToTasks lock less times than GetProgressDetail
func (*RunningTask) GetProgressDetail ¶
func (rt *RunningTask) GetProgressDetail(taskId uint64) *models.TaskProgressDetail
GetProgressDetail FIXME ...
func (*RunningTask) Remove ¶
func (rt *RunningTask) Remove(taskId uint64) (context.CancelFunc, errors.Error)
Remove FIXME ...
type RunningTaskData ¶
type RunningTaskData struct { Cancel context.CancelFunc ProgressDetail *models.TaskProgressDetail }
RunningTaskData FIXME ...