Package | Description |
---|---|
ds.granules.communication.direct | |
ds.granules.exchange |
This package contains classes related to processing exchanges.
|
ds.granules.operation |
This package encapsulates functionality related to application instances that will be deployed on the cloud.
|
ds.granules.util |
This package contains utility classes used by several components.
|
Modifier and Type | Method and Description |
---|---|
ProgressTracker |
JobDeployer.deployOperations(Operation[] operations) |
static JobDeployer |
JobDeployer.getInstance() |
void |
JobDeployer.initialize(Properties streamingProperties) |
Modifier and Type | Method and Description |
---|---|
DeploymentMessage |
ExchangeFactory.createDeploymentResponse(String jobIdentifier,
String taskIdentifier,
int exchangeSubType,
int conditionFlag,
String description)
Creates a deployment response, to a previously issued request.
|
DeploymentMessage |
ExchangeFactory.createDeploymentStatusOrAbortRequest(String jobIdentifier,
String taskIdentifier,
String respondTo,
int exchangeSubType)
Creates a DeploymentMessage that is a request for either getting the
STATUS or ABORTing a previously deployment operation.
|
DeploymentMessage |
ExchangeFactory.createDepoymentRequest(String jobIdentifier,
Operation operation,
String respondTo)
Creates a deployment request based on the specified parameters.
|
Constructor and Description |
---|
DeploymentMessage(String jobIdentifier,
Operation operation,
String respondTo)
Creates a deployment message based on the specified parameters.
|
DeploymentMessage(String jobIdentifier,
String taskIdentifier,
int exchangeSubType,
int conditionFlag,
String description)
Creates a deployment response, to a previously issued request.
|
DeploymentMessage(String jobIdentifier,
String taskIdentifier,
String respondTo,
int exchangeSubType)
Creates a DeploymentMessage that is a request for either getting the
STATUS or ABORTing a previously deployment operation.
|
Modifier and Type | Method and Description |
---|---|
void |
JobSubmission.abortTask(String jobIdentifier,
String taskIdentifier)
Send an abort request for a specific task.
|
ProgressTracker |
JobSubmission.deploy(Operation[] operations,
int numOfResources,
String jobIdentifier,
JobLifecycleObserver jobLifecycleObserver) |
ProgressTracker |
InstanceDeployer.deployOperations(Operation[] operations)
This method deploys a set of operations on a specified number of
resources.
|
ProgressTracker |
Deployer.deployOperations(Operation[] operations) |
ProgressTracker |
InstanceDeployer.deployOperations(Operation[] operations,
int numOfResources,
String jobIdentifier)
This method deploys a set of operations on a specified number of
resources.
|
ProgressTracker |
InstanceDeployer.deployOperations(Operation[] operations,
String jobIdentifier)
This method deploys a set of operations on the set of available
resources.
|
void |
JobSubmission.discoverResource()
Discovers the available computational resources.
|
void |
JobSubmission.discoverResource(int wait)
Discovers the available computational resources.
|
void |
JobSubmission.getStatusOfTask(String jobIdentifier,
String taskIdentifier)
Retrieve the status of a task.
|
void |
InstanceDeployer.initialize(Properties streamingProperties)
This initializes the deployer based on the specified argument.
|
void |
Deployer.initialize(Properties streamingProperties) |
void |
InstanceDeployer.initialize(Properties streamingProperties,
String commType)
This initializes the deployer based on the specified arguments.
|
void |
InstanceDeployer.initialize(String configurationFile,
int entityId,
Properties props,
String commType)
This initializes the deployer based on the specified arguments.
|
void |
JobSubmission.killJob(String jobIdentifier)
Attempts to kill the job while it is in execution at different sites
|
void |
InstanceDeployer.killJob(String jobIdentifier)
Kill a Job with specified jobIdentifer
|
void |
InstanceDeployer.refreshStatus(String jobIdentifier)
This method refreshes the status of various tasks that comprise a Job.
|
void |
InstanceDeployer.refreshStatus(String jobIdentifier,
String taskIdentifier)
This method refreshes the status of a specific task that is part of the
Job in question.
|
ProgressTracker |
JobSubmission.submit(Operation operation,
JobLifecycleObserver jobLifecycleObserver)
Submit the given operation for execution.
|
ProgressTracker |
JobSubmission.submit(Operation operation,
String resourceDeploymentStream,
JobLifecycleObserver jobLifecycleObserver)
Submit the given operation for execution.
|
ProgressTracker |
JobSubmission.submit(Operation operation,
String resourceDeploymentStream,
String jobIdentifier,
JobLifecycleObserver jobLifecycleObserver)
This method allows one to group a set of related tasks together in a Job.
|
Modifier and Type | Method and Description |
---|---|
Properties |
ParamsReader.getProperties(String configFileLocation)
Constructs a set of properties from the specified configuration file.
|
Copyright © 2015. All rights reserved.