scheduler

Documentation

Index

• Variables
• func Init()
• func Run()
• func SelectWorker(cfg model.PipelineConfig, workers []model.Worker) (model.Worker, error)
• type Context
  • func (s *Context) AddToQueue(ctx build.Context)
  • func (s *Context) ChangeInWorkers()
  • func (s *Context) Finished(ctx any)
  • func (s *Context) Schedule(buildID uuid.UUID)

Variables

var (
	ErrBuildSave       = errors.New("unable to save build to database")
	ErrBuildInitFailed = errors.New("build init ended with error")
)

var (
	ErrNoAvailableWorker                 = errors.New("no worker is available")
	ErrNoAvailableWorkerForConfiguration = errors.New("no worker is available for given configuration")
)

Functions

func Init

func Init()

func Run

func Run()

func SelectWorker

func SelectWorker(cfg model.PipelineConfig, workers []model.Worker) (model.Worker, error)

Types

type Context

type Context struct{}

func (*Context) AddToQueue

func (s *Context) AddToQueue(ctx build.Context)

func (*Context) ChangeInWorkers

func (s *Context) ChangeInWorkers()

func (*Context) Finished

func (s *Context) Finished(ctx any)

func (*Context) Schedule

func (s *Context) Schedule(buildID uuid.UUID)