ds.granules.scheduler

Class Diagnostics

java.lang.Object

ds.granules.scheduler.Diagnostics

public class Diagnostics
extends Object

This class keeps track of various diagnostic-related elements.

Author:

Shrideep Pallickara

Field Summary

Fields

Modifier and Type	Field and Description
static String	MODULE

Constructor Summary

Constructors

Constructor and Description
Diagnostics(String deploymentStream, int numOfThreads)

Method Summary

Methods

Modifier and Type	Method and Description
void	addDeploymentRequest(String taskIdentifier, DeploymentMessage deploymentRequest) Add the deployment request associated with the task.
void	averageRateOfTaskArrivals()
void	completedTask(String taskIdentifier) Process the completion of the task.
void	createdTask(String taskIdentifier, TaskLifecycleMetrics metrics) Manage information about the newly created task.
void	getNumberOfCompletedTasks()
ResourceMetrics	getResourceMetrics() Retrieve the resource metrics
TaskLifecycleMetrics	getStatusOfTask(String taskIdentifier) Retrieve the status associated with a specific task.
void	processExecutionStatusRequest(ExecutionStatus executionStatus)
void	processResourceDiscoveryRequest(ResourceDiscovery resourceDiscovery)
void	removeDeploymentRequest(String taskIdentifier) Remove the deployment request associated with a task.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE

public static final String MODULE

See Also:

Constant Field Values

Constructor Detail

Diagnostics

public Diagnostics(String deploymentStream,
           int numOfThreads)
            throws CommunicationsException

Throws:

CommunicationsException

Method Detail

getResourceMetrics

public ResourceMetrics getResourceMetrics()

Retrieve the resource metrics

Returns:

the resourceMetrics

addDeploymentRequest

public void addDeploymentRequest(String taskIdentifier,
                        DeploymentMessage deploymentRequest)

Add the deployment request associated with the task. This method is invoked BEFORE the task is deployed, so if the deployment fails the corresponding method to remove this request will be invoked.

Parameters:

taskIdentifier - The id of the task

deploymentRequest - The deployment request for the task in question.

removeDeploymentRequest

public void removeDeploymentRequest(String taskIdentifier)

Remove the deployment request associated with a task. This method is invoked if there are problems in deploying the operationa associated with the task.

Parameters:

taskIdentifier - The id of the task

createdTask

public void createdTask(String taskIdentifier,
               TaskLifecycleMetrics metrics)

Manage information about the newly created task.

Parameters:

taskIdentifier - The taskIdentifier assigned to the task

metrics - The lifecycle metrics associated with the task in question

completedTask

public void completedTask(String taskIdentifier)

Process the completion of the task.

Parameters:

taskIdentifier - The identifier associated with the task.

getStatusOfTask

public TaskLifecycleMetrics getStatusOfTask(String taskIdentifier)

Retrieve the status associated with a specific task.

Parameters:

taskIdentifier -

Returns:

The identifier associated with the task.

averageRateOfTaskArrivals

public void averageRateOfTaskArrivals()

getNumberOfCompletedTasks

public void getNumberOfCompletedTasks()

processResourceDiscoveryRequest

public void processResourceDiscoveryRequest(ResourceDiscovery resourceDiscovery)
                                     throws SuppressedException

Throws:

SuppressedException

processExecutionStatusRequest

public void processExecutionStatusRequest(ExecutionStatus executionStatus)
                                   throws SuppressedException

Throws:

SuppressedException