io.github.retz.scheduler

Class JobStatem

java.lang.Object

io.github.retz.scheduler.JobStatem

public class JobStatem
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JobStatem.Action

Constructor Summary

Constructors

Constructor and Description
JobStatem()

Method Summary

Modifier and Type	Method and Description
static JobStatem.Action	handleCall(Job job, org.apache.mesos.Protos.TaskState taskState) State diagram of Events and Job to callback action method name

Methods inherited from class java.lang.Object

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

Constructor Detail

JobStatem

public JobStatem()

Method Detail

handleCall

public static JobStatem.Action handleCall(Job job,
                                          org.apache.mesos.Protos.TaskState taskState)

State diagram of Events and Job to callback action method name

Events \ in Retz | QUEUED | STARTING | STARTED | FINISHED | KILLED -----------------------+----------+----------+----------+----------+---------- TASK_FINISHED_VALUE: | finished | finished | finished | noop | never TASK_ERROR_VALUE: | failed | failed | failed | never | noop TASK_FAILED_VALUE: | ^^ | ^^ | ^^ | ^^ | noop TASK_KILLED_VALUE: | ^^ | ^^ | ^^ | ^^ | noop TASK_LOST_VALUE: | noop | retry | retry | ^^ | noop TASK_KILLING_VALUE: | ^^ | noop | noop | noop | noop TASK_RUNNING_VALUE: | started | started | started | noop | noop TASK_STAGING_VALUE: | noop | noop | noop | noop | noop TASK_STARTING_VALUE: | starting | starting | noop | noop | noop TASK_DROPPED | noop | retry | retry | noop | noop TASK_UNREACHABLE | noop | log | log | noop | noop TASK_GONE | noop | retry | retry | noop | noop TASK_GONE_BY_OPERATOR| noop | log | log | noop | noop TASK_UNKNOWN | noop | log | log | noop | noop default | log | log | log | never | never (kill from user* | killed | killed | killed | noop | noop)

'kill from user' is at JobRequestHandler::kill TODO: Actual implementation is still different from this spec; fix it TODO: Add QuickCheck test to this state diagram TODO: Update Events periodically from mesos.proto (last updated on Jan 13 2017) State transitions: finished => FINISHED failed => KILLED retry => QUEUED noop => keep never => assert! could be a bug or race; write an error log log => unexpected; just write a warn log? started => STARTED starting => STARTING killed => KILLED

Parameters:

job - The job that requires some action (state)

taskState - Task state change (event)

Returns:

an Action that should be taken (action, indicates next state)