com.mesosphere.sdk.reconciliation

Class DefaultReconciler

java.lang.Object

com.mesosphere.sdk.reconciliation.DefaultReconciler

All Implemented Interfaces:

Reconciler

public class DefaultReconciler
extends java.lang.Object
implements Reconciler

Default implementation of Reconciler. See Reconciler for docs.

Constructor Summary

Constructors

Constructor and Description
DefaultReconciler(StateStore stateStore)

Method Summary

Modifier and Type	Method and Description
protected long	getCurrentTimeMillis() Time retrieval broken out into a separate function to allow overriding its behavior in tests.
boolean	isReconciled() Returns whether reconciliation is complete.
void	reconcile(SchedulerDriver driver) This function is expected to be called repeatedly.
(package private) java.util.Set<java.lang.String>	remaining() Returns the list of remaining unreconciled tasks for validation in tests.
void	start() Starts reconciliation against the provided tasks, which should represent what the Scheduler currently knows about task status.
void	update(Protos.TaskStatus status) Used to update the Reconciler with current task status.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultReconciler

public DefaultReconciler(StateStore stateStore)

Method Detail

start

public void start()

Description copied from interface: Reconciler

Starts reconciliation against the provided tasks, which should represent what the Scheduler currently knows about task status.

NOTE: THIS CALL MUST BE THREAD-SAFE AGAINST OTHER RECONCILER CALLS

Specified by:

start in interface Reconciler

reconcile

public void reconcile(SchedulerDriver driver)

This function is expected to be called repeatedly. It executes the following pseudocode across multiple calls: unreconciledList = tasksKnownByScheduler // provided by the StateStore while (!unreconciledList.isEmpty()) { // explicit reconciliation (PHASE 1) if (timerSinceLastCallExpired) { driver.reconcile(unreconciledList); } } driver.reconcile(emptyList); // implicit reconciliation (PHASE 2)

Specified by:

reconcile in interface Reconciler

Parameters:

driver - The SchedulerDriver instance that the Reconciler should use to query the Mesos master for TaskStatus.

update

public void update(Protos.TaskStatus status)

Description copied from interface: Reconciler

Used to update the Reconciler with current task status. This is effectively an asynchronous callback which is triggered by a call to reconcile().

NOTE: THIS CALL MUST BE THREAD-SAFE AGAINST OTHER RECONCILER CALLS

Specified by:

update in interface Reconciler

Parameters:

status - The TaskStatus used to update the Reconciler.

isReconciled

public boolean isReconciled()

Description copied from interface: Reconciler

Returns whether reconciliation is complete.

NOTE: THIS CALL MUST BE THREAD-SAFE AGAINST OTHER RECONCILER CALLS

Specified by:

isReconciled in interface Reconciler

remaining

java.util.Set<java.lang.String> remaining()

Returns the list of remaining unreconciled tasks for validation in tests.

getCurrentTimeMillis

protected long getCurrentTimeMillis()

Time retrieval broken out into a separate function to allow overriding its behavior in tests.