io.github.retz.scheduler

Class JobQueue

java.lang.Object

io.github.retz.scheduler.JobQueue

public class JobQueue
extends java.lang.Object

On memory job queue to mediate job execution requests and resources TODO: make all these data tolerant against node or network failure TODO: FIXME: re-design all exception handling, which to supress / which to return to client

Method Summary

Modifier and Type	Method and Description
static java.util.Optional<Job>	cancel(int id, java.lang.String reason)
static void	cancelAll(java.util.List<Job> jobs)
static void	clear()
static void	compact()
static int	countRunning()
static void	failed(java.lang.String taskId, java.util.Optional<java.lang.String> maybeUrl, java.lang.String msg)
static java.util.List<Job>	findFit(java.util.List<java.lang.String> orderBy, ResourceQuantity total)
static java.util.Optional<Job>	getFromTaskId(java.lang.String taskId)
static java.util.Optional<Job>	getJob(int id)
static int	issueJobId()
static java.util.List<Job>	list(java.lang.String user, Job.JobState state, java.util.Optional<java.lang.String> tag, int limit)
static void	push(Job job)
static java.util.List<Job>	queued(int limit)
static void	retry(java.lang.String taskId, java.lang.String reason)
static int	size()
static void	starting(Job job, java.util.Optional<java.lang.String> url, java.lang.String taskId)
static Job	updateJobStatus(Job job, java.lang.String stateInMesos)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

list

public static java.util.List<Job> list(java.lang.String user,
                                       Job.JobState state,
                                       java.util.Optional<java.lang.String> tag,
                                       int limit)
                                throws java.io.IOException,
                                       java.sql.SQLException

Throws:

java.io.IOException

java.sql.SQLException

issueJobId

public static int issueJobId()

push

public static void push(Job job)
                 throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

cancelAll

public static void cancelAll(java.util.List<Job> jobs)

cancel

public static java.util.Optional<Job> cancel(int id,
                                             java.lang.String reason)
                                      throws java.sql.SQLException,
                                             java.io.IOException,
                                             JobNotFoundException

Throws:

java.sql.SQLException

java.io.IOException

JobNotFoundException

findFit

public static java.util.List<Job> findFit(java.util.List<java.lang.String> orderBy,
                                          ResourceQuantity total)

queued

public static java.util.List<Job> queued(int limit)
                                  throws java.sql.SQLException,
                                         java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

getJob

public static java.util.Optional<Job> getJob(int id)

clear

public static void clear()

size

public static int size()

starting

public static void starting(Job job,
                            java.util.Optional<java.lang.String> url,
                            java.lang.String taskId)

getFromTaskId

public static java.util.Optional<Job> getFromTaskId(java.lang.String taskId)

retry

public static void retry(java.lang.String taskId,
                         java.lang.String reason)
                  throws java.sql.SQLException,
                         JobNotFoundException

Throws:

java.sql.SQLException

JobNotFoundException

failed

public static void failed(java.lang.String taskId,
                          java.util.Optional<java.lang.String> maybeUrl,
                          java.lang.String msg)
                   throws java.sql.SQLException,
                          JobNotFoundException

Throws:

java.sql.SQLException

JobNotFoundException

countRunning

public static int countRunning()

compact

public static void compact()

updateJobStatus

public static Job updateJobStatus(Job job,
                                  java.lang.String stateInMesos)