dispatch

Documentation

Overview

Package dispatch provides a service to dispatch jobs to the runner.

Index

• func CheckJobStatus(old api.Status, target api.Status) bool
• func CheckStepStatus(old api.Status, target api.Status) bool
• type Service
  • func NewService(dbClient *db.Client, eventhook *eventhook.Service) *Service
  • func (s *Service) Dispatch(ctx context.Context, jobs []*db.Job, executions []*db.JobExecution) error
  • func (s *Service) UpdateJobExecution(ctx context.Context, client *db.Client, option *db.UpdateJobExecutionOption) error

Functions

func CheckJobStatus

func CheckJobStatus(old api.Status, target api.Status) bool

CheckJobStatus checks the ability to transit from old to target status. It's only used for job status transition.

func CheckStepStatus

func CheckStepStatus(old api.Status, target api.Status) bool

CheckStepStatus checks the ability to transit from old to target status. It's only used for step status transition.

Types

type Service

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

func NewService

func NewService(dbClient *db.Client, eventhook *eventhook.Service) *Service

func (*Service) Dispatch

func (s *Service) Dispatch(ctx context.Context, jobs []*db.Job, executions []*db.JobExecution) error

Dispatch dispatches the jobs and updates the job executions. It pushes the jobs to the queue if all the dependencies are completed and success. TODO: proceed dispatch if one job is failed, all the dependent jobs should be skipped.

func (*Service) UpdateJobExecution

func (s *Service) UpdateJobExecution(ctx context.Context, client *db.Client, option *db.UpdateJobExecutionOption) error

UpdateJobExecution updates job execution status and job queue status. It insert a new job queue if the job execution status is queued.