public class SchedulerConfig
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
SchedulerConfig.ConfigException
Exception which is thrown when failing to retrieve or parse a given flag value.
|
Modifier and Type | Method and Description |
---|---|
static SchedulerConfig |
fromEnv()
Returns a new
SchedulerConfig instance which is based off the process environment. |
static SchedulerConfig |
fromMap(java.util.Map<java.lang.String,java.lang.String> map)
Returns a new
SchedulerConfig instance which is based off the provided custom environment map. |
java.time.Duration |
getApiServerInitTimeout()
Returns the configured time to wait for the API server to come up during scheduler initialization.
|
int |
getApiServerPort()
Returns the configured API port, or throws
SchedulerConfig.ConfigException if the environment lacked the required
information. |
java.lang.String |
getBootstrapURI() |
TokenProvider |
getDcosAuthTokenProvider()
Returns a token provider which may be used to retrieve DC/OS JWT auth tokens, or throws an exception if the local
environment doesn't provide the needed information (e.g.
|
java.lang.String |
getDcosSpace() |
java.lang.String |
getExecutorURI() |
java.lang.String |
getJavaHome() |
java.lang.String |
getJavaURI() |
java.lang.String |
getLibmesosURI() |
java.lang.String |
getMesosApiVersion()
Returns the Mesos API version.
|
long |
getPackageBuildTimeMs()
Returns the package build time (unix epoch milliseconds) as advertised in the scheduler environment.
|
java.lang.String |
getPackageName()
Returns the package name as advertised in the scheduler environment.
|
java.lang.String |
getPackageVersion()
Returns the package version as advertised in the scheduler environment.
|
java.lang.String |
getPauseOverrideCmd()
Returns the command to be run when pausing a Task.
|
java.lang.String |
getSecretsNamespace(java.lang.String serviceName) |
java.lang.String |
getStatsdHost()
Returns the StatsD host.
|
long |
getStatsDPollIntervalS()
Returns the interval in seconds between StatsD reports.
|
int |
getStatsdPort()
Returns the StatsD port.
|
boolean |
isregionAwarenessEnabled() |
boolean |
isSideChannelActive()
Returns whether it appears that side channel auth should be used when creating the SchedulerDriver.
|
boolean |
isStateCacheEnabled() |
boolean |
isUninstallEnabled() |
public static SchedulerConfig fromEnv()
SchedulerConfig
instance which is based off the process environment.public static SchedulerConfig fromMap(java.util.Map<java.lang.String,java.lang.String> map)
SchedulerConfig
instance which is based off the provided custom environment map.public java.time.Duration getApiServerInitTimeout()
public int getApiServerPort()
SchedulerConfig.ConfigException
if the environment lacked the required
information.public java.lang.String getExecutorURI()
public java.lang.String getBootstrapURI()
public java.lang.String getLibmesosURI()
public java.lang.String getJavaURI()
public java.lang.String getJavaHome()
public java.lang.String getDcosSpace()
public java.lang.String getSecretsNamespace(java.lang.String serviceName)
public boolean isStateCacheEnabled()
public boolean isUninstallEnabled()
public boolean isSideChannelActive()
public TokenProvider getDcosAuthTokenProvider() throws java.io.IOException
java.io.IOException
public java.lang.String getPackageName()
public java.lang.String getPackageVersion()
public long getPackageBuildTimeMs()
public long getStatsDPollIntervalS()
public java.lang.String getStatsdHost()
public int getStatsdPort()
public java.lang.String getMesosApiVersion()
public java.lang.String getPauseOverrideCmd()
public boolean isregionAwarenessEnabled()