services

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 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 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
  • func NewNotificationService(endpoint, secret string) *NotificationService
  • func (n *NotificationService) PipelineStatusChanged(params PipelineNotification) error
• 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

Functions

func CancelPipeline

func CancelPipeline(pipelineId uint64) error

CancelPipeline FIXME ...

func CancelTask

func CancelTask(taskId uint64) error

CancelTask FIXME ...

func CreateBlueprint

func CreateBlueprint(blueprint *models.Blueprint) error

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

func CreateTask(newTask *models.NewTask) (*models.Task, error)

CreateTask FIXME ...

func DeleteBlueprint

func DeleteBlueprint(id uint64) error

DeleteBlueprint FIXME ...

func ExecuteMigration

func ExecuteMigration() error

func GeneratePlanJson

func GeneratePlanJson(settings json.RawMessage) (json.RawMessage, error)

GeneratePlanJson generates pipeline plan by version

func GeneratePlanJsonV100

func GeneratePlanJsonV100(settings *models.BlueprintSettings) (core.PipelinePlan, error)

GeneratePlanJsonV100 generates pipeline plan according v1.0.0 definition

func GetBlueprint

func GetBlueprint(blueprintId uint64) (*models.Blueprint, error)

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 GetPipeline

func GetPipeline(pipelineId uint64) (*models.Pipeline, error)

GetPipeline by id

func GetPipelines

func GetPipelines(query *PipelineQuery) ([]*models.Pipeline, int64, error)

GetPipelines by query

func GetPluginsApiResources

func GetPluginsApiResources() (map[string]map[string]map[string]core.ApiResourceHandler, error)

GetPluginsApiResources return value

{
	"jira": {
		"connections": {
			"POST": *ApiResourceHandler
		}
	}
}

func GetRepos

func GetRepos() ([]*code.Repo, int64, error)

GetRepos FIXME ...

func GetTask

func GetTask(taskId uint64) (*models.Task, error)

GetTask FIXME ...

func GetTasks

func GetTasks(query *TaskQuery) ([]models.Task, int64, error)

GetTasks FIXME ...

func Init

func Init()

Init the services module

func InsertRow

func InsertRow(table string, rows []map[string]interface{}) (int64, error)

InsertRow FIXME ...

func MergePipelinePlans

func MergePipelinePlans(plans ...core.PipelinePlan) core.PipelinePlan

MergePipelinePlans merges multiple pipelines into one unified pipeline

func MigrationRequireConfirmation

func MigrationRequireConfirmation() bool

func NotifyExternal

func NotifyExternal(pipelineId uint64) error

NotifyExternal FIXME ...

func PatchBlueprint

func PatchBlueprint(id uint64, body map[string]interface{}) (*models.Blueprint, error)

PatchBlueprint FIXME ...

func ReloadBlueprints

func ReloadBlueprints(c *cron.Cron) error

ReloadBlueprints FIXME ...

func RunPipelineInQueue

func RunPipelineInQueue(pipelineMaxParallel int64)

RunPipelineInQueue query pipeline from db and run it in a queue

func TriggerBlueprint

func TriggerBlueprint(id uint64) (*models.Pipeline, error)

TriggerBlueprint triggers blueprint immediately

Types

type BlueprintQuery

type BlueprintQuery struct {
	Enable   *bool `form:"enable,omitempty"`
	Page     int   `form:"page"`
	PageSize int   `form:"pageSize"`
}

BlueprintQuery FIXME ...

type NotificationService

type NotificationService struct {
	EndPoint string
	Secret   string
}

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 ...

type TaskQuery

type TaskQuery struct {
	Status     string `form:"status"`
	Page       int    `form:"page"`
	PageSize   int    `form:"page_size"`
	Plugin     string `form:"plugin"`
	PipelineId uint64 `form:"pipelineId" uri:"pipelineId"`
	Pending    int    `form:"pending"`
}

TaskQuery FIXME ...