com.mesosphere.sdk.reconciliation

Interface Reconciler

All Known Implementing Classes:

DefaultReconciler

public interface Reconciler

Interface for a task Reconciler, which synchronizes the Framework's task state with what Mesos reports (with Mesos treated as source of truth).

Method Summary

Modifier and Type	Method and Description
boolean	isReconciled() Returns whether reconciliation is complete.
void	reconcile(SchedulerDriver driver) Triggers any needed reconciliation against the provided driver.
void	start() Starts reconciliation against the provided tasks, which should represent what the Scheduler currently knows about task status.
void	update(TaskStatus status) Used to update the Reconciler with current task status.

Method Detail

start

void start()

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

reconcile

void reconcile(SchedulerDriver driver)

Triggers any needed reconciliation against the provided driver. This call is expected to occur multiple times throughout the lifespan of the scheduler. It SHOULD be invoked each time that the scheduler receives a TaskStatus update or an Offer.

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

Parameters:

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

update

void update(TaskStatus status)

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

Parameters:

status - The TaskStatus used to update the Reconciler.

isReconciled

boolean isReconciled()

Returns whether reconciliation is complete.

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