scheduler

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

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

type Scheduler interface {
	List()

	FinishedJudgement() chan *models.Judgement

	NewRuntime(problem *models.Problem, submission *models.Submission, judgement *models.Judgement, process *models.Process) (*Runtime, error)
	PushRuntime(runtime *Runtime) error
	FinishRuntime(runtime *Runtime)

	FetchTask(judgementId, taskId, taskType string, ignoreLock bool) *TaskElement
	FinishTask(element *TaskElement, slots *models.Slots) error
	FinishTaskWithError(element *TaskElement, message string) error
	LockTask(element *TaskElement) bool
	UnlockTask(element *TaskElement) bool
}

type TaskElement struct {
	IsLocked bool
	LockedAt time.Time

	BlockId int
	Task    *models.Task
	// contains filtered or unexported fields
}