services

Documentation

Index

• func CancelPipeline(pipelineId uint64) error
• func CancelTask(taskId uint64) error
• func CreatePipeline(newPipeline *models.NewPipeline) (*models.Pipeline, error)
• func CreateTask(newTask *models.NewTask) (*models.Task, 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 GetTask(taskId uint64) (*models.Task, error)
• func GetTasks(query *TaskQuery) ([]models.Task, int64, error)
• func NotifyExternal(pipelineId uint64) error
• func RunPipeline(pipelineId uint64) error
• func RunTask(taskId uint64) error
• 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) Remove(taskId uint64) (context.CancelFunc, error)
• type TaskQuery

Functions

func CancelPipeline

func CancelPipeline(pipelineId uint64) error

func CancelTask

func CancelTask(taskId uint64) error

func CreatePipeline

func CreatePipeline(newPipeline *models.NewPipeline) (*models.Pipeline, error)

func CreateTask

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

func GetPipeline

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

func GetPipelines

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

func GetPluginsApiResources

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

* return value

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

func GetTask

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

func GetTasks

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

func NotifyExternal

func NotifyExternal(pipelineId uint64) error

func RunPipeline

func RunPipeline(pipelineId uint64) error

func RunTask

func RunTask(taskId uint64) error

RunTask guarantees database is update even if it panicked, and the error will be returned to caller

Types

type NotificationService

type NotificationService struct {
	EndPoint string
	Secret   string
}

func NewNotificationService

func NewNotificationService(endpoint, secret string) *NotificationService

func (*NotificationService) PipelineStatusChanged

func (n *NotificationService) PipelineStatusChanged(params PipelineNotification) error

type PipelineNotification

type PipelineNotification struct {
	PipelineID uint64
	CreatedAt  time.Time
	UpdatedAt  time.Time
	BeganAt    *time.Time
	FinishedAt *time.Time
	Status     string
}

type PipelineQuery

type PipelineQuery struct {
	Status   string `form:"status"`
	Pending  int    `form:"pending"`
	Page     int    `form:"page"`
	PageSize int    `form:"page_size"`
}

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) Remove

func (rt *RunningTask) Remove(taskId uint64) (context.CancelFunc, error)

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"`
}