Documentation
¶
Index ¶
- Variables
- 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 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 InsertRow(table string, rows []map[string]interface{}) (int64, error)
- func NotifyExternal(pipelineId uint64) error
- func ReloadBlueprints(c *cron.Cron) error
- func RunPipeline(pipelineId uint64) error
- func UpdateBlueprint(blueprint *models.Blueprint) 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 ¶
View Source
var ACTIVITY_PATTERN = regexp.MustCompile(`task #(\d+)`)
Functions ¶
func CancelPipeline ¶
func CancelTask ¶
func CreateBlueprint ¶
func CreatePipeline ¶
func CreatePipeline(newPipeline *models.NewPipeline) (*models.Pipeline, error)
func DeleteBlueprint ¶
func GetBlueprints ¶
func GetBlueprints(query *BlueprintQuery) ([]*models.Blueprint, int64, error)
func GetPipelines ¶
func GetPipelines(query *PipelineQuery) ([]*models.Pipeline, int64, error)
func GetPluginsApiResources ¶
* return value
{
"jira": {
"connections": {
"POST": *ApiResourceHandler
}
}
}
func NotifyExternal ¶
func ReloadBlueprints ¶
func RunPipeline ¶
func UpdateBlueprint ¶
Types ¶
type BlueprintQuery ¶
type NotificationService ¶
func NewNotificationService ¶
func NewNotificationService(endpoint, secret string) *NotificationService
func (*NotificationService) PipelineStatusChanged ¶
func (n *NotificationService) PipelineStatusChanged(params PipelineNotification) error
type PipelineNotification ¶
type PipelineQuery ¶
type RunningTask ¶
type RunningTask struct {
// contains filtered or unexported fields
}
func (*RunningTask) Add ¶
func (rt *RunningTask) Add(taskId uint64, cancel context.CancelFunc) error
func (*RunningTask) FillProgressDetailToTasks ¶
func (rt *RunningTask) FillProgressDetailToTasks(tasks []models.Task)
less lock times than GetProgressDetail
func (*RunningTask) GetProgressDetail ¶
func (rt *RunningTask) GetProgressDetail(taskId uint64) *models.TaskProgressDetail
func (*RunningTask) Remove ¶
func (rt *RunningTask) Remove(taskId uint64) (context.CancelFunc, error)
type RunningTaskData ¶
type RunningTaskData struct {
Cancel context.CancelFunc
ProgressDetail *models.TaskProgressDetail
}
Click to show internal directories.
Click to hide internal directories.