com.mesosphere.sdk.scheduler

Class SchedulerRunner

java.lang.Object

com.mesosphere.sdk.scheduler.SchedulerRunner

All Implemented Interfaces:

java.lang.Runnable

public class SchedulerRunner
extends java.lang.Object
implements java.lang.Runnable

Class which sets up and executes the correct AbstractScheduler instance.

Method Summary

Modifier and Type	Method and Description
static SchedulerRunner	fromRawServiceSpec(RawServiceSpec rawServiceSpec, SchedulerConfig schedulerConfig, java.io.File configTemplateDir) Builds a new instance using a RawServiceSpec representing the raw object model of a YAML service specification file.
static SchedulerRunner	fromSchedulerBuilder(SchedulerBuilder schedulerBuilder) Builds a new instance using a SchedulerBuilder instance representing the scheduler logic to be executed.
static SchedulerRunner	fromServiceSpec(ServiceSpec serviceSpec, SchedulerConfig schedulerConfig) Builds a new instance using a ServiceSpec representing the serializable Java representation of a service specification.
void	run() Runs the scheduler.

Methods inherited from class java.lang.Object

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

Method Detail

fromRawServiceSpec

public static SchedulerRunner fromRawServiceSpec(RawServiceSpec rawServiceSpec,
                                                 SchedulerConfig schedulerConfig,
                                                 java.io.File configTemplateDir)
                                          throws java.lang.Exception

Builds a new instance using a RawServiceSpec representing the raw object model of a YAML service specification file.

Parameters:

rawServiceSpec - the object model of a YAML service specification file

schedulerConfig - the scheduler configuration to use (usually based on process environment)

configTemplateDir - the directory where any configuration templates are located (usually the parent directory of the YAML service specification file)

Returns:

a new SchedulerRunner instance, which may be launched with run()

Throws:

java.lang.Exception

fromServiceSpec

public static SchedulerRunner fromServiceSpec(ServiceSpec serviceSpec,
                                              SchedulerConfig schedulerConfig)
                                       throws PersisterException

Builds a new instance using a ServiceSpec representing the serializable Java representation of a service specification.

Parameters:

serviceSpec - the service specification converted to be used by the config store

schedulerConfig - the scheduler configuration to use (usually based on process environment)

Returns:

a new SchedulerRunner instance, which may be launched with run()

Throws:

PersisterException

fromSchedulerBuilder

public static SchedulerRunner fromSchedulerBuilder(SchedulerBuilder schedulerBuilder)

Builds a new instance using a SchedulerBuilder instance representing the scheduler logic to be executed.

Parameters:

schedulerBuilder - the (likely customized) scheduler object to be run by the runner

Returns:

a new SchedulerRunner instance, which may be launched with run()

run

public void run()

Runs the scheduler. Don't forget to call this! This should never exit, instead the entire process will be terminated internally.

Specified by:

run in interface java.lang.Runnable