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 GeneratePlanJson(settings datatypes.JSON) (datatypes.JSON, 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 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 NotifyExternal(pipelineId uint64) error
- func PatchBlueprint(id uint64, body map[string]interface{}) (*models.Blueprint, error)
- func ReloadBlueprints(c *cron.Cron) error
- func RunPipeline(pipelineId uint64) error
- 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 FIXME ...
func CreatePipeline ¶
func CreatePipeline(newPipeline *models.NewPipeline) (*models.Pipeline, error)
CreatePipeline FIXME ...
func CreateTask ¶
CreateTask FIXME ...
func GeneratePlanJson ¶ added in v0.12.0
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 FIXME ...
func GetBlueprints ¶
func GetBlueprints(query *BlueprintQuery) ([]*models.Blueprint, int64, error)
GetBlueprints FIXME ...
func GetPipeline ¶
GetPipeline FIXME ...
func GetPipelines ¶
func GetPipelines(query *PipelineQuery) ([]*models.Pipeline, int64, error)
GetPipelines FIXME ...
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 PatchBlueprint ¶ added in v0.12.0
PatchBlueprint FIXME ...
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"` }
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 ...