com.mesosphere.sdk.scheduler

Class DefaultScheduler

java.lang.Object

com.mesosphere.sdk.scheduler.AbstractScheduler

com.mesosphere.sdk.scheduler.DefaultScheduler

public class DefaultScheduler
extends AbstractScheduler

This scheduler when provided with a ServiceSpec will deploy the service and recover from encountered faults when possible. Changes to the ServiceSpec will result in rolling configuration updates, or the creation of new Tasks where applicable.

Field Summary

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

configStore, schedulerConfig, stateStore, statusExecutor

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

DefaultScheduler(ServiceSpec serviceSpec, SchedulerConfig schedulerConfig, java.util.Collection<java.lang.Object> customResources, java.util.Collection<Plan> plans, StateStore stateStore, ConfigStore<ServiceSpec> configStore, java.util.Map<java.lang.String,EndpointProducer> customEndpointProducers, java.util.Optional<RecoveryPlanOverriderFactory> recoveryPlanOverriderFactory) Creates a new DefaultScheduler.

Method Summary

Modifier and Type	Method and Description
(package private) PlanCoordinator	getPlanCoordinator()
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.
static SchedulerBuilder	newBuilder(ServiceSpec serviceSpec, SchedulerConfig schedulerConfig) Creates a new SchedulerBuilder based on the provided ServiceSpec describing the service, including details such as the service name, the pods/tasks to be deployed, and the plans describing how the deployment should be organized.
static SchedulerBuilder	newBuilder(ServiceSpec serviceSpec, SchedulerConfig schedulerConfig, Persister persister) Creates a new SchedulerBuilder based on the provided ServiceSpec describing the service, including details such as the service name, the pods/tasks to be deployed, and the plans describing how the deployment should be organized.
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, getMesosScheduler, getPlans, setOfferQueueSize, start

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultScheduler

protected DefaultScheduler(ServiceSpec serviceSpec,
                           SchedulerConfig schedulerConfig,
                           java.util.Collection<java.lang.Object> customResources,
                           java.util.Collection<Plan> plans,
                           StateStore stateStore,
                           ConfigStore<ServiceSpec> configStore,
                           java.util.Map<java.lang.String,EndpointProducer> customEndpointProducers,
                           java.util.Optional<RecoveryPlanOverriderFactory> recoveryPlanOverriderFactory)

Creates a new DefaultScheduler. See information about parameters in SchedulerBuilder.

Method Detail

newBuilder

public static SchedulerBuilder newBuilder(ServiceSpec serviceSpec,
                                          SchedulerConfig schedulerConfig)
                                   throws PersisterException

Creates a new SchedulerBuilder based on the provided ServiceSpec describing the service, including details such as the service name, the pods/tasks to be deployed, and the plans describing how the deployment should be organized.

Throws:

PersisterException

newBuilder

public static SchedulerBuilder newBuilder(ServiceSpec serviceSpec,
                                          SchedulerConfig schedulerConfig,
                                          Persister persister)
                                   throws PersisterException

Creates a new SchedulerBuilder based on the provided ServiceSpec describing the service, including details such as the service name, the pods/tasks to be deployed, and the plans describing how the deployment should be organized.

Throws:

PersisterException

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.Exception

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.Exception

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

getPlanCoordinator

PlanCoordinator getPlanCoordinator()