public class ReconciliationCoordinator extends Object implements akka.actor.Actor, akka.actor.FSM<ReconciliationCoordinator.TaskState,ReconciliationCoordinator.ReconciliationData>
Implements the reconciliation procedures as outlined here: http://mesos.apache.org/documentation/latest/reconciliation/
Modifier and Type | Class and Description |
---|---|
static class |
ReconciliationCoordinator.Idle$
The state of idling when reconciliation is not underway.
|
static class |
ReconciliationCoordinator.Reconcile
Initiates the task reconciliation process.
|
static class |
ReconciliationCoordinator.Reconcile$ |
static class |
ReconciliationCoordinator.ReconciliationData
The state data of the reconciliation coordinator.
|
static class |
ReconciliationCoordinator.ReconciliationData$ |
static class |
ReconciliationCoordinator.Reconciling$
The state of active reconciliation.
|
static class |
ReconciliationCoordinator.Suspended$
The state of being disconnected from Mesos.
|
static interface |
ReconciliationCoordinator.TaskState
An abstract FSM state.
|
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 |
---|
ReconciliationCoordinator(Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver) |
Modifier and Type | Method and Description |
---|---|
static <T extends ReconciliationCoordinator> |
createActorProps(Class<T> actorClass,
Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver)
Create the properties for a reconciliation coordinator.
|
static scala.concurrent.duration.FiniteDuration |
INITIAL_RECONCILIATION_TIMEOUT() |
grizzled.slf4j.Logger |
LOG() |
static scala.concurrent.duration.FiniteDuration |
RECONCILIATION_MAX_BACKOFF() |
static scala.concurrent.duration.FiniteDuration |
RECONCILIATION_MIN_BACKOFF() |
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 ReconciliationCoordinator(Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver)
public static scala.concurrent.duration.FiniteDuration INITIAL_RECONCILIATION_TIMEOUT()
public static scala.concurrent.duration.FiniteDuration RECONCILIATION_MIN_BACKOFF()
public static scala.concurrent.duration.FiniteDuration RECONCILIATION_MAX_BACKOFF()
public static <T extends ReconciliationCoordinator> akka.actor.Props createActorProps(Class<T> actorClass, Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver)
public grizzled.slf4j.Logger LOG()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.