com.mesosphere.sdk.scheduler

Class SchedulerDriverFactory

java.lang.Object

com.mesosphere.sdk.scheduler.SchedulerDriverFactory

public class SchedulerDriverFactory
extends java.lang.Object

Factory class for creating MesosSchedulerDrivers.

Constructor Summary

Constructors

Constructor and Description
SchedulerDriverFactory()

Method Summary

Modifier and Type	Method and Description
SchedulerDriver	create(Scheduler scheduler, FrameworkInfo frameworkInfo, java.lang.String masterUrl, SchedulerConfig schedulerConfig) Creates and returns a new SchedulerDriver without a credential secret.
SchedulerDriver	create(Scheduler scheduler, FrameworkInfo frameworkInfo, java.lang.String masterUrl, SchedulerConfig schedulerConfig, byte[] credentialSecret) Creates and returns a new SchedulerDriver with the provided credential secret.
protected SchedulerDriver	createInternal(Scheduler scheduler, FrameworkInfo frameworkInfo, java.lang.String masterUrl, Credential credential, java.lang.String mesosAPIVersion) Broken out into a separate function to allow testing with custom SchedulerDrivers.

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulerDriverFactory

public SchedulerDriverFactory()

Method Detail

create

public SchedulerDriver create(Scheduler scheduler,
                              FrameworkInfo frameworkInfo,
                              java.lang.String masterUrl,
                              SchedulerConfig schedulerConfig)

Creates and returns a new SchedulerDriver without a credential secret.

Parameters:

scheduler - The Framework Scheduler implementation which should receive callbacks from the SchedulerDriver

frameworkInfo - The FrameworkInfo which describes the framework implementation. The 'principal' field MUST be populated and non-empty

masterUrl - The URL of the currently active Mesos Master, of the form "zk://host/mesos"

Returns:

A SchedulerDriver configured with the provided info

Throws:

java.lang.IllegalArgumentException - if FrameworkInfo.principal is unset or empty when authentication is needed

create

public SchedulerDriver create(Scheduler scheduler,
                              FrameworkInfo frameworkInfo,
                              java.lang.String masterUrl,
                              SchedulerConfig schedulerConfig,
                              byte[] credentialSecret)

Creates and returns a new SchedulerDriver with the provided credential secret.

Parameters:

scheduler - The Framework Scheduler implementation which should receive callbacks from the SchedulerDriver

frameworkInfo - The FrameworkInfo which describes the framework implementation. The 'principal' field MUST be populated and non-empty

masterUrl - The URL of the currently active Mesos Master, of the form "zk://host/mesos"

credentialSecret - The secret to be included in the framework org.apache.mesos.Protos.Credential, ignored if null/empty

Returns:

A SchedulerDriver configured with the provided info

Throws:

java.lang.IllegalArgumentException - if FrameworkInfo.principal is unset or empty when authentication is needed

createInternal

protected SchedulerDriver createInternal(Scheduler scheduler,
                                         FrameworkInfo frameworkInfo,
                                         java.lang.String masterUrl,
                                         Credential credential,
                                         java.lang.String mesosAPIVersion)

Broken out into a separate function to allow testing with custom SchedulerDrivers.