scheduler

Documentation

Index

• Variables
• type Runtime
• type Scheduler
  • func New(logger *zap.Logger, problem *models.Problem, submission *models.Submission, ...) (*Scheduler, error)
  • func (s *Scheduler) Execute()
  • func (s *Scheduler) OnFinish() <-chan int

Variables

var ProviderSet = wire.NewSet(New)

Types

type Runtime

type Runtime struct {
	Blueprint  *models.Blueprint
	Problem    *models.Problem
	Submission *models.Submission
	Judgement  *models.Judgement
	// contains filtered or unexported fields
}

type Scheduler

type Scheduler struct {
	Runtime *Runtime

	C chan int
	// contains filtered or unexported fields
}

func New

func New(logger *zap.Logger,
	problem *models.Problem, submission *models.Submission, judgement *models.Judgement,
	blueprint *models.Blueprint, programs []*models.Program,
) (*Scheduler, error)

func (*Scheduler) Execute

func (s *Scheduler) Execute()

func (*Scheduler) OnFinish

func (s *Scheduler) OnFinish() <-chan int