services

Documentation

Index

• Constants
• func CancelTask(taskId uint64) error
• func CreateTaskInDB(data NewTask) (*models.Task, error)
• func CreateTasksInDBFromJSON(data [][]NewTask) [][]models.Task
• func GetPluginsApiResources() (map[string]map[string]map[string]core.ApiResourceHandler, error)
• func GetTasks(status string) ([]models.Task, error)
• func RunAllTasks(data [][]NewTask, tasks [][]models.Task) (err error)
• func RunTask(task models.Task, data NewTask, taskComplete chan bool) (models.Task, error)
• type NewTask
• type NotificationService
  • func NewNotificationService(endpoint, secret string) *NotificationService
  • func (n *NotificationService) TaskSuccess(params TaskSuccessNotification) error
• type TaskSuccessNotification

Constants

const (
	TASK_CREATED   = "TASK_CREATED"
	TASK_COMPLETED = "TASK_COMPLETED"
	TASK_FAILED    = "TASK_FAILED"
)

Functions

func CancelTask

func CancelTask(taskId uint64) error

func CreateTaskInDB

func CreateTaskInDB(data NewTask) (*models.Task, error)

func CreateTasksInDBFromJSON

func CreateTasksInDBFromJSON(data [][]NewTask) [][]models.Task

func GetPluginsApiResources

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

* return value

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

func GetTasks

func GetTasks(status string) ([]models.Task, error)

func RunAllTasks

func RunAllTasks(data [][]NewTask, tasks [][]models.Task) (err error)

func RunTask

func RunTask(task models.Task, data NewTask, taskComplete chan bool) (models.Task, error)

Types

type NewTask

type NewTask struct {
	// Plugin name
	Plugin string `json:"plugin" binding:"required"`
	// Options for the plugin task to be triggered
	Options map[string]interface{} `json:"options" binding:"required"`
}

type NotificationService

type NotificationService struct {
	EndPoint string
	Secret   string
}

func NewNotificationService

func NewNotificationService(endpoint, secret string) *NotificationService

func (*NotificationService) TaskSuccess

func (n *NotificationService) TaskSuccess(params TaskSuccessNotification) error

type TaskSuccessNotification

type TaskSuccessNotification struct {
	TaskID     uint64
	PluginName string
	CreatedAt  time.Time
	UpdatedAt  time.Time
}