com.mesosphere.sdk.scheduler

Class SchedulerUtils

java.lang.Object

com.mesosphere.sdk.scheduler.SchedulerUtils

public class SchedulerUtils
extends java.lang.Object

This class provides utilities common to the construction and operation of Mesos Schedulers.

Constructor Summary

Constructors

Constructor and Description
SchedulerUtils()

Method Summary

Modifier and Type	Method and Description
(package private) static java.util.Optional<Plan>	getDeployPlan(java.util.Collection<Plan> plans)
static java.lang.String	getServiceName(RawServiceSpec rawServiceSpec) Returns the configured service name (aka framework name) to use for running the service.
static java.lang.String	getServicePrincipal(RawServiceSpec rawServiceSpec) Returns the configured Mesos principal to use for running the service.
static java.lang.String	getServiceRole(RawServiceSpec rawServiceSpec) Returns the configured Mesos role to use for running the service.
static java.lang.String	getUser(RawServiceSpec rawServiceSpec) Returns the configured user to use for running the scheduler.
static java.lang.String	getZkHost(RawServiceSpec rawServiceSpec, SchedulerConfig schedulerConfig) Returns the configured hostname:port to use for state storage at the scheduler.
static void	hardExit(SchedulerErrorCode errorCode) Immediately exits the process with the ordinal value of the provided errorCode.
static java.lang.String	withEscapedSlashes(java.lang.String frameworkName) Removes any slashes from the provided framework name and replaces them with double underscores.

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulerUtils

public SchedulerUtils()

Method Detail

getServiceName

public static java.lang.String getServiceName(RawServiceSpec rawServiceSpec)

Returns the configured service name (aka framework name) to use for running the service.

Throws:

java.lang.IllegalArgumentException - if no service name could be found

withEscapedSlashes

public static java.lang.String withEscapedSlashes(java.lang.String frameworkName)

Removes any slashes from the provided framework name and replaces them with double underscores. For example:

• /path/to/kafka => path__to__kafka
• path/to/some-kafka => path__to__some-kafka
• path__to__kafka => EXCEPTION

Throws:

java.lang.IllegalArgumentException - if the provided framework name already contains double underscores

getServiceRole

public static java.lang.String getServiceRole(RawServiceSpec rawServiceSpec)

Returns the configured Mesos role to use for running the service. For example: /path/to/kafka => path__to__kafka-role

getServicePrincipal

public static java.lang.String getServicePrincipal(RawServiceSpec rawServiceSpec)

Returns the configured Mesos principal to use for running the service.

getZkHost

public static java.lang.String getZkHost(RawServiceSpec rawServiceSpec,
                                         SchedulerConfig schedulerConfig)

Returns the configured hostname:port to use for state storage at the scheduler.

getUser

public static java.lang.String getUser(RawServiceSpec rawServiceSpec)

Returns the configured user to use for running the scheduler.

hardExit

public static void hardExit(SchedulerErrorCode errorCode)

Immediately exits the process with the ordinal value of the provided errorCode.

getDeployPlan

static java.util.Optional<Plan> getDeployPlan(java.util.Collection<Plan> plans)