service

Documentation

Index

• Variables
• type TaskService
  • func NewTaskService(db *gorm.DB, tasks []task.Task) *TaskService
  • func (ts *TaskService) GetTask(taskName string) (*task.Task, string)
  • func (ts *TaskService) ListTasks() []task.Task
  • func (ts *TaskService) SyncDbTasks() error
• type WorkerService
  • func NewWorkerService(db *gorm.DB, tasks []task.Task) *WorkerService
  • func (ws *WorkerService) NextRun() (db.Run, task.Task, error)
  • func (ws *WorkerService) ReportRun(req openapi.ReportWorkV1Request) error
  • func (ws *WorkerService) ScheduleRun(reason db.RunReason, repositoryName string, scheduleAfter time.Time, ...) (uint, error)

Variables

var ErrNoRun = errors.New("no next run")

Types

type TaskService

type TaskService struct {
	// contains filtered or unexported fields
}

func NewTaskService

func NewTaskService(db *gorm.DB, tasks []task.Task) *TaskService

func (*TaskService) GetTask

func (ts *TaskService) GetTask(taskName string) (*task.Task, string)

func (*TaskService) ListTasks

func (ts *TaskService) ListTasks() []task.Task

func (*TaskService) SyncDbTasks

func (ts *TaskService) SyncDbTasks() error

type WorkerService

type WorkerService struct {
	// contains filtered or unexported fields
}

func NewWorkerService

func NewWorkerService(db *gorm.DB, tasks []task.Task) *WorkerService

func (*WorkerService) NextRun

func (ws *WorkerService) NextRun() (db.Run, task.Task, error)

func (*WorkerService) ReportRun

func (ws *WorkerService) ReportRun(req openapi.ReportWorkV1Request) error

func (*WorkerService) ScheduleRun

func (ws *WorkerService) ScheduleRun(
	reason db.RunReason,
	repositoryName string,
	scheduleAfter time.Time,
	taskName string,
	tx *gorm.DB,
) (uint, error)