public class TaskMonitor extends Object implements akka.actor.Actor, akka.actor.FSM<TaskMonitor.TaskMonitorState,TaskMonitor.StateData>
Models a task with a state machine reflecting the perceived state of the task in Mesos. The state is primarily updated when task status information arrives from Mesos.
The associated state data primarily tracks the task's goal (intended) state, as persisted by the scheduler. Keep in mind that goal state is persisted before actions are taken. The goal state strictly transitions thru New->Launched->Released.
Unlike most exchanges with Mesos, task status is delivered at-least-once, so status handling should be idempotent.
Modifier and Type | Class and Description |
---|---|
static class |
TaskMonitor.Killing$ |
static class |
TaskMonitor.Launched |
static class |
TaskMonitor.Launched$ |
static class |
TaskMonitor.New |
static class |
TaskMonitor.New$ |
static class |
TaskMonitor.Reconciling$ |
static class |
TaskMonitor.Released |
static class |
TaskMonitor.Released$ |
static class |
TaskMonitor.Running$ |
static class |
TaskMonitor.Staging$ |
static class |
TaskMonitor.StateData |
static class |
TaskMonitor.StateData$ |
static class |
TaskMonitor.Suspended$ |
static interface |
TaskMonitor.TaskGoalState |
static class |
TaskMonitor.TaskGoalStateUpdated
Conveys an update to the goal (intentional) state of a given task.
|
static class |
TaskMonitor.TaskGoalStateUpdated$ |
static interface |
TaskMonitor.TaskMonitorState
An FSM state of the task monitor, roughly corresponding to the task status.
|
static class |
TaskMonitor.TaskTerminated
Indicates that the Mesos task has terminated for whatever reason.
|
static class |
TaskMonitor.TaskTerminated$ |
akka.actor.FSM.$minus$greater$, akka.actor.FSM.CurrentState<S>, akka.actor.FSM.CurrentState$, akka.actor.FSM.Event<D>, akka.actor.FSM.Event$, akka.actor.FSM.Failure, akka.actor.FSM.Failure$, akka.actor.FSM.LogEntry<S,D>, akka.actor.FSM.LogEntry$, akka.actor.FSM.Normal$, akka.actor.FSM.NullFunction$, akka.actor.FSM.Reason, akka.actor.FSM.Shutdown$, akka.actor.FSM.State<S,D>, akka.actor.FSM.State$, akka.actor.FSM.StateTimeout$, akka.actor.FSM.StopEvent<S,D>, akka.actor.FSM.StopEvent$, akka.actor.FSM.SubscribeTransitionCallBack, akka.actor.FSM.SubscribeTransitionCallBack$, akka.actor.FSM.TimeoutMarker, akka.actor.FSM.TimeoutMarker$, akka.actor.FSM.Timer, akka.actor.FSM.Timer$, akka.actor.FSM.TransformHelper, akka.actor.FSM.Transition<S>, akka.actor.FSM.Transition$, akka.actor.FSM.UnsubscribeTransitionCallBack, akka.actor.FSM.UnsubscribeTransitionCallBack$
Constructor and Description |
---|
TaskMonitor(Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver,
TaskMonitor.TaskGoalState goalState) |
Modifier and Type | Method and Description |
---|---|
static akka.actor.FSM.$minus$greater$ |
$minus$greater() |
static void |
applyState(akka.actor.FSM.State<S,D> nextState) |
protected static void |
aroundPostRestart(Throwable reason) |
protected static void |
aroundPostStop() |
protected static void |
aroundPreRestart(Throwable reason,
scala.Option<Object> message) |
protected static void |
aroundPreStart() |
protected static void |
aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive,
Object msg) |
static void |
cancelTimer(String name) |
static akka.actor.ActorContext |
context() |
static <T extends TaskMonitor> |
createActorProps(Class<T> actorClass,
Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver,
TaskMonitor.TaskGoalState goalState)
Creates the properties for the TaskMonitor actor.
|
static boolean |
debugEvent() |
static akka.actor.FSM.Event$ |
Event() |
protected static void |
gossip(Object msg,
akka.actor.ActorRef sender) |
protected static akka.actor.ActorRef |
gossip$default$2(Object msg) |
static void |
initialize() |
static boolean |
isStateTimerActive() |
static boolean |
isTimerActive(String name) |
static scala.concurrent.duration.FiniteDuration |
LAUNCH_TIMEOUT() |
protected static scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
listenerManagement() |
protected static Set<akka.actor.ActorRef> |
listeners() |
static akka.event.LoggingAdapter |
log() |
grizzled.slf4j.Logger |
LOG() |
protected static void |
logTermination(akka.actor.FSM.Reason reason) |
static void |
makeTransition(akka.actor.FSM.State<S,D> nextState) |
static D |
nextStateData() |
static void |
onTermination(scala.PartialFunction<akka.actor.FSM.StopEvent<S,D>,scala.runtime.BoxedUnit> terminationHandler) |
static void |
onTransition(scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> transitionHandler) |
static void |
postRestart(Throwable reason) |
static void |
postStop() |
static void |
preRestart(Throwable reason,
scala.Option<Object> message) |
static void |
preStart() |
static void |
processEvent(akka.actor.FSM.Event<D> event,
Object source) |
static scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
static scala.concurrent.duration.FiniteDuration |
RETRY_INTERVAL() |
static akka.actor.ActorRef |
self() |
static akka.actor.ActorRef |
sender() |
static void |
setStateTimeout(S state,
scala.Option<scala.concurrent.duration.FiniteDuration> timeout) |
static void |
setTimer(String name,
Object msg,
scala.concurrent.duration.FiniteDuration timeout,
boolean repeat) |
static boolean |
setTimer$default$4() |
static void |
startWith(S stateName,
D stateData,
scala.Option<scala.concurrent.duration.FiniteDuration> timeout) |
static scala.Option<scala.concurrent.duration.FiniteDuration> |
startWith$default$3() |
static D |
stateData() |
static S |
stateName() |
static akka.actor.FSM.StateTimeout$ |
StateTimeout() |
static akka.actor.FSM.State<S,D> |
stay() |
static akka.actor.FSM.State<S,D> |
stop() |
static akka.actor.FSM.State<S,D> |
stop(akka.actor.FSM.Reason reason) |
static akka.actor.FSM.State<S,D> |
stop(akka.actor.FSM.Reason reason,
D stateData) |
static akka.actor.FSM.StopEvent$ |
StopEvent() |
static akka.actor.SupervisorStrategy |
supervisorStrategy() |
static scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> |
total2pf(scala.Function2<S,S,scala.runtime.BoxedUnit> transitionHandler) |
static akka.actor.FSM.TransformHelper |
transform(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> func) |
static void |
unhandled(Object message) |
static void |
when(S stateName,
scala.concurrent.duration.FiniteDuration stateTimeout,
scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction) |
static scala.concurrent.duration.FiniteDuration |
when$default$2() |
static void |
whenUnhandled(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
$minus$greater, akka$actor$FSM$_setter_$$minus$greater_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq, akka$actor$FSM$_setter_$Event_$eq, akka$actor$FSM$_setter_$StateTimeout_$eq, akka$actor$FSM$_setter_$StopEvent_$eq, akka$actor$FSM$$currentState_$eq, akka$actor$FSM$$currentState, akka$actor$FSM$$generation_$eq, akka$actor$FSM$$generation, akka$actor$FSM$$handleEvent_$eq, akka$actor$FSM$$handleEvent, akka$actor$FSM$$handleEventDefault, akka$actor$FSM$$nextState_$eq, akka$actor$FSM$$nextState, akka$actor$FSM$$stateFunctions, akka$actor$FSM$$stateTimeouts, akka$actor$FSM$$super$postStop, akka$actor$FSM$$terminateEvent_$eq, akka$actor$FSM$$terminateEvent, akka$actor$FSM$$timeoutFuture_$eq, akka$actor$FSM$$timeoutFuture, akka$actor$FSM$$timerGen, akka$actor$FSM$$timers, akka$actor$FSM$$transitionEvent_$eq, akka$actor$FSM$$transitionEvent, applyState, cancelTimer, debugEvent, Event, goto, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextStateData, onTermination, onTransition, postStop, processEvent, receive, setStateTimeout, setTimer, setTimer$default$4, startWith, startWith$default$3, stateData, stateName, StateTimeout, stay, stop, stop, stop, StopEvent, total2pf, transform, when, when$default$2, whenUnhandled
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled
public TaskMonitor(Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver, TaskMonitor.TaskGoalState goalState)
public static scala.concurrent.duration.FiniteDuration RETRY_INTERVAL()
public static scala.concurrent.duration.FiniteDuration LAUNCH_TIMEOUT()
public static <T extends TaskMonitor> akka.actor.Props createActorProps(Class<T> actorClass, Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver, TaskMonitor.TaskGoalState goalState)
actorClass
- the task monitor actor classflinkConfig
- the Flink configurationschedulerDriver
- the Mesos scheduler drivergoalState
- the task's goal statepublic static akka.actor.ActorContext context()
public static final akka.actor.ActorRef self()
public static final akka.actor.ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive, Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(Throwable reason, scala.Option<Object> message)
protected static void aroundPostRestart(Throwable reason)
public static akka.actor.SupervisorStrategy supervisorStrategy()
public static void preRestart(Throwable reason, scala.Option<Object> message) throws Exception
Exception
public static void unhandled(Object message)
protected static Set<akka.actor.ActorRef> listeners()
protected static scala.PartialFunction<Object,scala.runtime.BoxedUnit> listenerManagement()
protected static void gossip(Object msg, akka.actor.ActorRef sender)
protected static akka.actor.ActorRef gossip$default$2(Object msg)
public static akka.event.LoggingAdapter log()
public static akka.actor.FSM.Event$ Event()
public static akka.actor.FSM.StopEvent$ StopEvent()
public static akka.actor.FSM.$minus$greater$ $minus$greater()
public static akka.actor.FSM.StateTimeout$ StateTimeout()
public static final void when(S stateName, scala.concurrent.duration.FiniteDuration stateTimeout, scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction)
public static final void startWith(S stateName, D stateData, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
public static final akka.actor.FSM.State<S,D> stay()
public static final akka.actor.FSM.State<S,D> stop()
public static final akka.actor.FSM.State<S,D> stop(akka.actor.FSM.Reason reason)
public static final akka.actor.FSM.State<S,D> stop(akka.actor.FSM.Reason reason, D stateData)
public static final akka.actor.FSM.TransformHelper transform(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> func)
public static final void setTimer(String name, Object msg, scala.concurrent.duration.FiniteDuration timeout, boolean repeat)
public static final void cancelTimer(String name)
public static final boolean isTimerActive(String name)
public static final void setStateTimeout(S state, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
public static final boolean isStateTimerActive()
public static final void onTransition(scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> transitionHandler)
public static final scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> total2pf(scala.Function2<S,S,scala.runtime.BoxedUnit> transitionHandler)
public static final void onTermination(scala.PartialFunction<akka.actor.FSM.StopEvent<S,D>,scala.runtime.BoxedUnit> terminationHandler)
public static final void whenUnhandled(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction)
public static final void initialize()
public static final S stateName()
public static final D stateData()
public static final D nextStateData()
public static boolean debugEvent()
public static scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
public static void processEvent(akka.actor.FSM.Event<D> event, Object source)
public static void applyState(akka.actor.FSM.State<S,D> nextState)
public static void makeTransition(akka.actor.FSM.State<S,D> nextState)
public static void postStop()
protected static void logTermination(akka.actor.FSM.Reason reason)
public static final scala.concurrent.duration.FiniteDuration when$default$2()
public static final scala.Option<scala.concurrent.duration.FiniteDuration> startWith$default$3()
public static final boolean setTimer$default$4()
public grizzled.slf4j.Logger LOG()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.