Documentation ¶
Index ¶
- func CancelPipeline(pipelineId uint64) error
- func CancelTask(taskId uint64) error
- func CreateBlueprint(blueprint *models.Blueprint) error
- func CreatePipeline(newPipeline *models.NewPipeline) (*models.Pipeline, error)
- func CreateTask(newTask *models.NewTask) (*models.Task, error)
- func DeleteBlueprint(id uint64) error
- func ExecuteMigration() error
- func FormatPipelinePlans(beforePlanJson json.RawMessage, mainPlan core.PipelinePlan, ...) (core.PipelinePlan, error)
- func GeneratePlanJson(settings json.RawMessage) (json.RawMessage, error)
- func GeneratePlanJsonV100(settings *models.BlueprintSettings) (core.PipelinePlan, error)
- func GetBlueprint(blueprintId uint64) (*models.Blueprint, error)
- func GetBlueprints(query *BlueprintQuery) ([]*models.Blueprint, int64, error)
- func GetPipeline(pipelineId uint64) (*models.Pipeline, error)
- func GetPipelineLogsArchivePath(pipeline *models.Pipeline) (string, error)
- func GetPipelines(query *PipelineQuery) ([]*models.Pipeline, int64, error)
- func GetPluginsApiResources() (map[string]map[string]map[string]core.ApiResourceHandler, error)
- func GetRepos() ([]*code.Repo, int64, error)
- func GetTask(taskId uint64) (*models.Task, error)
- func GetTasks(query *TaskQuery) ([]models.Task, int64, error)
- func Init()
- func InsertRow(table string, rows []map[string]interface{}) (int64, error)
- func MergePipelinePlans(plans ...core.PipelinePlan) core.PipelinePlan
- func MigrationRequireConfirmation() bool
- func NotifyExternal(pipelineId uint64) error
- func PatchBlueprint(id uint64, body map[string]interface{}) (*models.Blueprint, error)
- func ReloadBlueprints(c *cron.Cron) error
- func RunPipelineInQueue(pipelineMaxParallel int64)
- func TriggerBlueprint(id uint64) (*models.Pipeline, error)
- type BlueprintQuery
- type NotificationService
- type PipelineNotification
- type PipelineQuery
- type RunningTask
- func (rt *RunningTask) Add(taskId uint64, cancel context.CancelFunc) error
- func (rt *RunningTask) FillProgressDetailToTasks(tasks []models.Task)
- func (rt *RunningTask) GetProgressDetail(taskId uint64) *models.TaskProgressDetail
- func (rt *RunningTask) Remove(taskId uint64) (context.CancelFunc, error)
- type RunningTaskData
- type TaskQuery
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateBlueprint ¶
CreateBlueprint accepts a Blueprint instance and insert it to database
func CreatePipeline ¶
func CreatePipeline(newPipeline *models.NewPipeline) (*models.Pipeline, error)
CreatePipeline and return the model
func CreateTask ¶
CreateTask FIXME ...
func ExecuteMigration ¶ added in v0.12.0
func ExecuteMigration() error
func FormatPipelinePlans ¶ added in v0.13.0
func FormatPipelinePlans(beforePlanJson json.RawMessage, mainPlan core.PipelinePlan, afterPlanJson json.RawMessage) (core.PipelinePlan, 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, error)
GeneratePlanJson generates pipeline plan by version
func GeneratePlanJsonV100 ¶ added in v0.12.0
func GeneratePlanJsonV100(settings *models.BlueprintSettings) (core.PipelinePlan, error)
GeneratePlanJsonV100 generates pipeline plan according v1.0.0 definition
func GetBlueprint ¶
GetBlueprint returns the detail of a given Blueprint ID
func GetBlueprints ¶
func GetBlueprints(query *BlueprintQuery) ([]*models.Blueprint, int64, error)
GetBlueprints returns a paginated list of Blueprints based on `query`
func GetPipelineLogsArchivePath ¶ added in v0.13.0
GetPipelineLogsArchivePath creates an archive for the logs of this pipeline and returns its file path
func GetPipelines ¶
func GetPipelines(query *PipelineQuery) ([]*models.Pipeline, int64, error)
GetPipelines by query
func GetPluginsApiResources ¶
GetPluginsApiResources return value
{ "jira": { "connections": { "POST": *ApiResourceHandler } } }
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
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) 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 `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) 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, error)
Remove FIXME ...
type RunningTaskData ¶
type RunningTaskData struct { Cancel context.CancelFunc ProgressDetail *models.TaskProgressDetail }
RunningTaskData FIXME ...