ds.granules.scheduler

Interface TaskLifecycleObserver

All Known Implementing Classes:

TaskManagement

public interface TaskLifecycleObserver

The observer whose method invocation track the lifetime of a task

Author:

Shrideep Pallickara

Method Summary

Modifier and Type	Method and Description
void	abnormalOperationTermination(java.lang.String taskIdentifier, java.lang.String reason) Indicates that the task in question has terminated abnormally.
void	isChangedPeriodicExecution(java.lang.String taskIdentifier) Indicates that the task in question has changed it execution profile.
void	isComplete(java.lang.String taskIdentifier) Indicates that the task in question has finished processing.
void	isExecuting(java.lang.String taskIdentifier) Indicates that the task in question has been scheduled for execution and is currently executing.
void	isInitializing(java.lang.String taskIdentifier) Indicates that the task is question is currently performing initialization related operations.
void	isReady(java.lang.String taskIdentifier) When a task is ready for execution, this method is invoked on its registered observer.
void	isWaitingForData(java.lang.String taskIdentifier) Indicates that the task in question is waiting for the arrival of data to begin processing.

Method Detail

isReady

void isReady(java.lang.String taskIdentifier)

When a task is ready for execution, this method is invoked on its registered observer.

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

isInitializing

void isInitializing(java.lang.String taskIdentifier)

Indicates that the task is question is currently performing initialization related operations.

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

isExecuting

void isExecuting(java.lang.String taskIdentifier)

Indicates that the task in question has been scheduled for execution and is currently executing.

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

isWaitingForData

void isWaitingForData(java.lang.String taskIdentifier)

Indicates that the task in question is waiting for the arrival of data to begin processing.

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

isComplete

void isComplete(java.lang.String taskIdentifier)

Indicates that the task in question has finished processing.

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

abnormalOperationTermination

void abnormalOperationTermination(java.lang.String taskIdentifier,
                                  java.lang.String reason)

Indicates that the task in question has terminated abnormally. Typically, this happens when a error is reported by the execute() method of the Operation.

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.

reason - A description of the cause of the error.

isChangedPeriodicExecution

void isChangedPeriodicExecution(java.lang.String taskIdentifier)

Indicates that the task in question has changed it execution profile. This could be a changed in the execution interval for periodic execution, or it could be a change from periodic execution to one that is no-periodic.

Parameters:

taskIdentifier - The identifier of the Task whose life cycle transition is being reported on.