com.mesosphere.sdk.scheduler.uninstall

Class UninstallScheduler

java.lang.Object

com.mesosphere.sdk.scheduler.AbstractScheduler

com.mesosphere.sdk.scheduler.uninstall.UninstallScheduler

public class UninstallScheduler
extends AbstractScheduler

This scheduler uninstalls the framework and releases all of its resources.

Field Summary

Fields inherited from class com.mesosphere.sdk.scheduler.AbstractScheduler

configStore, schedulerConfig, stateStore, statusExecutor

Constructor Summary

Constructors

Modifier	Constructor and Description
	UninstallScheduler(ServiceSpec serviceSpec, StateStore stateStore, ConfigStore<ServiceSpec> configStore, SchedulerConfig schedulerConfig) Creates a new UninstallScheduler based on the provided API port and initialization timeout, and a StateStore.
protected	UninstallScheduler(ServiceSpec serviceSpec, StateStore stateStore, ConfigStore<ServiceSpec> configStore, SchedulerConfig schedulerConfig, java.util.Optional<SecretsClient> customSecretsClientForTests)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<Scheduler>	getMesosScheduler() Returns a Mesos API Scheduler object to be registered with Mesos, or an empty Optional if Mesos registration should not be performed.
java.util.Collection<java.lang.Object>	getResources() Returns a list of API resources to be served by the scheduler to the local cluster.
protected PlanCoordinator	initialize(SchedulerDriver driver) Performs any additional Scheduler initialization after registration has completed.
protected void	processOffers(SchedulerDriver driver, java.util.List<Protos.Offer> offers, java.util.Collection<Step> steps) The abstract scheduler will periodically call this method with a list of available offers, which may be empty.
protected void	processStatusUpdate(Protos.TaskStatus status) Handles a task status update which was received from Mesos.

Methods inherited from class com.mesosphere.sdk.scheduler.AbstractScheduler

awaitOffersProcessed, disableApiServer, disableThreading, getPlans, setOfferQueueSize, start

Methods inherited from class java.lang.Object

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

Constructor Detail

UninstallScheduler

public UninstallScheduler(ServiceSpec serviceSpec,
                          StateStore stateStore,
                          ConfigStore<ServiceSpec> configStore,
                          SchedulerConfig schedulerConfig)

Creates a new UninstallScheduler based on the provided API port and initialization timeout, and a StateStore. The UninstallScheduler builds an uninstall Plan which will clean up the service's reservations, TLS artifacts, zookeeper data, and any other artifacts from running the service.

UninstallScheduler

protected UninstallScheduler(ServiceSpec serviceSpec,
                             StateStore stateStore,
                             ConfigStore<ServiceSpec> configStore,
                             SchedulerConfig schedulerConfig,
                             java.util.Optional<SecretsClient> customSecretsClientForTests)

Method Detail

getMesosScheduler

public java.util.Optional<Scheduler> getMesosScheduler()

Description copied from class: AbstractScheduler

Returns a Mesos API Scheduler object to be registered with Mesos, or an empty Optional if Mesos registration should not be performed.

Overrides:

getMesosScheduler in class AbstractScheduler

getResources

public java.util.Collection<java.lang.Object> getResources()

Description copied from class: AbstractScheduler

Returns a list of API resources to be served by the scheduler to the local cluster. This may be called before AbstractScheduler.initialize(SchedulerDriver) has been called.

Specified by:

getResources in class AbstractScheduler

initialize

protected PlanCoordinator initialize(SchedulerDriver driver)
                              throws java.lang.InterruptedException

Description copied from class: AbstractScheduler

Performs any additional Scheduler initialization after registration has completed. The provided SchedulerDriver may be used to talk to Mesos. Returns a PlanCoordinator which will be used to select candidate workloads.

Specified by:

initialize in class AbstractScheduler

Throws:

java.lang.InterruptedException

processOffers

protected void processOffers(SchedulerDriver driver,
                             java.util.List<Protos.Offer> offers,
                             java.util.Collection<Step> steps)

Description copied from class: AbstractScheduler

The abstract scheduler will periodically call this method with a list of available offers, which may be empty.

Specified by:

processOffers in class AbstractScheduler

processStatusUpdate

protected void processStatusUpdate(Protos.TaskStatus status)

Description copied from class: AbstractScheduler

Handles a task status update which was received from Mesos. This call is executed on a separate thread which is run by the Mesos Scheduler Driver.

Specified by:

processStatusUpdate in class AbstractScheduler