edu.iu.dsc.tws.rsched.schedulers.nomad

Class NomadContext

java.lang.Object

edu.iu.dsc.tws.api.config.Context

edu.iu.dsc.tws.api.config.SchedulerContext

edu.iu.dsc.tws.rsched.schedulers.nomad.NomadContext

public class NomadContext
extends SchedulerContext

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CORE_PACKAGE_ENV
static java.lang.String	DOWNLOAD_PACKAGE_ENV
static java.lang.String	JOB_PACKAGE_ENV
static java.lang.String	LOGGING_SANDBOX
static java.lang.String	NOMAD_DEFAULT_DATACENTER
static java.lang.String	NOMAD_IMAGE
static java.lang.String	NOMAD_JOB_NAME
static java.lang.String	NOMAD_SCRIPT_NAME
static java.lang.String	NOMAD_SHELL_SCRIPT
static java.lang.String	NOMAD_TASK_COMMAND
static java.lang.String	NOMAD_TASK_COMMAND_ARGS
static java.lang.String	NOMAD_URI
static java.lang.String	PORT_NAMES
static java.lang.String	SHARED_FILE_SYSTEM
static java.lang.String	SHELL_CMD
static java.lang.String	WORKING_DIRECTORY_ENV

Fields inherited from class edu.iu.dsc.tws.api.config.SchedulerContext

ADDITIONAL_PORTS, CLUSTER_TYPE, CONFIG_DIR, COPY_SYSTEM_PACKAGE, CORE_PACKAGE_FILENAME, CORE_PACKAGE_FILENAME_DEFAULT, CORE_PACKAGE_URL, DATACENTER_LABEL_KEY, DATACENTERS_LIST, DEBUG, DOWNLOAD_METHOD, DRIVER_CLASS, JOB_ARCHIVE_TEMP_DIR, JOB_DESCRIPTION_FILE_CMD_VAR, JOB_MASTER_PROVIDED_IP, JOB_PACKAGE_FILENAME, JOB_PACKAGE_FILENAME_DEFAULT, JOB_PACKAGE_URI, JOB_PACKAGE_URL, K8S_CHECK_PODS_REACHABLE, K8S_CHECK_PODS_REACHABLE_DEFAULT, LAUNCHER_CLASS, NETWORK_INTERFACES, NFS_SERVER_ADDRESS, NFS_SERVER_PATH, PERSISTENT_VOLUME_PER_WORKER, PERSISTENT_VOLUME_PER_WORKER_DEFAULT, RACK_LABEL_KEY, RACKS_LIST, SYSTEM_PACKAGE_URI, TEMPORARY_PACKAGES_PATH, THREADS_PER_WORKER, TWISTER_2_HOME, TWISTER2_PACKAGES_PATH, UPLOADER_CLASS, USER_JOB_FILE, USER_JOB_TYPE, WORKER_CLASS, WORKER_COMPUTE_RESOURCES, WORKING_DIRECTORY

Fields inherited from class edu.iu.dsc.tws.api.config.Context

AURORA_SCRIPT, CHECKPOINT_YAML, CLUSTER, CLUSTER_CONF, CLUSTER_HOME, CORE_YAML, DATA_YAML, defaults, GRAPH_TYPE, HOME, JAVA_HOME, JOB, JOB_ARCHIVE_DIRECTORY, JOB_ID, JOB_NAME, JOB_OBJECT, NETWORK_YAML, OPERATION_NAME, OVERRIDE_YAML, RESOURCE_SCHEDULER_YAML, STREAMING, substitutions, TASK_YAML, TWISTER2_BANDWIDTH, TWISTER2_BIN, TWISTER2_CLUSTER_TYPE, TWISTER2_COMMON_CONF_DIR, TWISTER2_CONF, TWISTER2_CONTAINER_ID, TWISTER2_DIRECT_EDGE, TWISTER2_DIST, TWISTER2_GRAPH_JOB, TWISTER2_HOME, TWISTER2_LATENCY, TWISTER2_LIB, TWISTER2_MAX_TASK_INSTANCES_PER_WORKER, TWISTER2_TASK_INSTANCE_ODD_PARALLELISM, TWISTER2_TSET_JOB, TWISTER2_WORKER_INSTANCES, TWISTER2_WORKER_INSTANCES_DEFAULT, USER_NAME, VERBOSE

Constructor Summary

Constructors

Constructor and Description
NomadContext()

Method Summary

Modifier and Type	Method and Description
static java.util.Map<java.lang.String,java.lang.Integer>	generateAdditionalPorts(Config config, int workerPort)
static boolean	getLoggingSandbox(Config config)
static java.lang.String	networkPortNames(Config config)
static java.lang.String	nomadSchedulerUri(Config config)
static boolean	sharedFileSystem(Config config)
static java.lang.String	shellScriptName(Config config)
static java.lang.String	workingDirectory(Config config)

Methods inherited from class edu.iu.dsc.tws.api.config.SchedulerContext

additionalPorts, checkPodsReachable, copySystemPackage, corePackageFileName, corePackageUrl, createJobDescriptionFileName, downloadMethod, driverClass, getJobMasterProvidedIp, getNodeInfo, isLocalFileSystemUploader, jobArchiveTempDirectory, jobPackageFileName, jobPackageUri, jobPackageUrl, launcherClass, networkInterfaces, nfsServerAddress, nfsServerPath, numberOfAdditionalPorts, packagesPath, persistentVolumePerWorker, persistentVolumeRequested, systemPackageUrl, temporaryPackagesPath, uploaderClass, useOpenMPI, userJobJarFile, userJobType, workerClass, workerEndSyncWaitTime

Methods inherited from class edu.iu.dsc.tws.api.config.Context

auroraScript, checkpointCofigurationFile, checkpointConfigurationFile, clusterType, commonConfDir, conf, containerId, dataConfigurationFile, distDirectory, getDefaults, getDoublePropertyValue, getIntPropertyValue, getLongPropertyValue, getStringPropertyValue, isKubernetesCluster, jobId, jobName, libDirectory, networkConfigurationFile, resourceSchedulerConfigurationFile, systemConfigurationFile, taskConfigurationFile, twister2Home, userName, verbose, workerInstances

Methods inherited from class java.lang.Object

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

Field Detail

WORKING_DIRECTORY_ENV

public static final java.lang.String WORKING_DIRECTORY_ENV

See Also:

Constant Field Values

DOWNLOAD_PACKAGE_ENV

public static final java.lang.String DOWNLOAD_PACKAGE_ENV

See Also:

Constant Field Values

CORE_PACKAGE_ENV

public static final java.lang.String CORE_PACKAGE_ENV

See Also:

Constant Field Values

JOB_PACKAGE_ENV

public static final java.lang.String JOB_PACKAGE_ENV

See Also:

Constant Field Values

NOMAD_TASK_COMMAND

public static final java.lang.String NOMAD_TASK_COMMAND

See Also:

Constant Field Values

NOMAD_TASK_COMMAND_ARGS

public static final java.lang.String NOMAD_TASK_COMMAND_ARGS

See Also:

Constant Field Values

NOMAD_IMAGE

public static final java.lang.String NOMAD_IMAGE

See Also:

Constant Field Values

NOMAD_DEFAULT_DATACENTER

public static final java.lang.String NOMAD_DEFAULT_DATACENTER

See Also:

Constant Field Values

SHELL_CMD

public static final java.lang.String SHELL_CMD

See Also:

Constant Field Values

NOMAD_JOB_NAME

public static final java.lang.String NOMAD_JOB_NAME

See Also:

Constant Field Values

PORT_NAMES

public static final java.lang.String PORT_NAMES

See Also:

Constant Field Values

SHARED_FILE_SYSTEM

public static final java.lang.String SHARED_FILE_SYSTEM

See Also:

Constant Field Values

NOMAD_SHELL_SCRIPT

public static final java.lang.String NOMAD_SHELL_SCRIPT

See Also:

Constant Field Values

NOMAD_SCRIPT_NAME

public static final java.lang.String NOMAD_SCRIPT_NAME

See Also:

Constant Field Values

NOMAD_URI

public static final java.lang.String NOMAD_URI

See Also:

Constant Field Values

LOGGING_SANDBOX

public static final java.lang.String LOGGING_SANDBOX

See Also:

Constant Field Values

Constructor Detail

NomadContext

public NomadContext()

Method Detail

workingDirectory

public static java.lang.String workingDirectory(Config config)

sharedFileSystem

public static boolean sharedFileSystem(Config config)

networkPortNames

public static java.lang.String networkPortNames(Config config)

shellScriptName

public static java.lang.String shellScriptName(Config config)

nomadSchedulerUri

public static java.lang.String nomadSchedulerUri(Config config)

getLoggingSandbox

public static boolean getLoggingSandbox(Config config)

generateAdditionalPorts

public static java.util.Map<java.lang.String,java.lang.Integer> generateAdditionalPorts(Config config,
                                                                                        int workerPort)