co.cask.coopr.scheduler.task

Class TaskQueueService

java.lang.Object

co.cask.coopr.scheduler.task.TaskQueueService

public class TaskQueueService
extends Object

Manages handing out tasks from task queue, and recording status after the task is done.

Method Summary

Methods

Modifier and Type	Method and Description
void	finishClusterTask(FinishTaskRequest finishRequest) Records the status of a finished task from provisioner.
Map<String,QueueMetrics>	getTaskQueueMetricsSnapshot() Get a snapshot of the number of queued and in progress elements for all queues in the task queues.
QueueMetrics	getTaskQueueMetricsSnapshot(String tenantId) Get the queue metrics for the given tenant.
String	takeNextClusterTask(TakeTaskRequest takeRequest) Returns the next task from task queue that can be handed out for provisioning.

Methods inherited from class java.lang.Object

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

Method Detail

getTaskQueueMetricsSnapshot

public Map<String,QueueMetrics> getTaskQueueMetricsSnapshot()
                                                     throws IOException

Get a snapshot of the number of queued and in progress elements for all queues in the task queues.

Returns:

Snapshot of the number of queued and in progress elements in the task queues

Throws:

IOException

getTaskQueueMetricsSnapshot

public QueueMetrics getTaskQueueMetricsSnapshot(String tenantId)
                                         throws IOException

Get the queue metrics for the given tenant.

Parameters:

tenantId - Id of the tenant to get queue metrics for

Returns:

Queue metrics for the tenants

Throws:

IOException

takeNextClusterTask

public String takeNextClusterTask(TakeTaskRequest takeRequest)
                           throws IOException,
                                  MissingEntityException

Returns the next task from task queue that can be handed out for provisioning. When it goes through the task queue, if it gets a task whose job is already marked as FAILED then the task gets marked as DROPPED, and is skipped.

Parameters:

takeRequest - Request to take a task.

Returns:

Task JSON to be handed over to the provisioner.

Throws:

MissingEntityException - if there is no provisioner for the provisioner id in the request.

IOException - if there was an error persisting task information.

finishClusterTask

public void finishClusterTask(FinishTaskRequest finishRequest)
                       throws MissingEntityException,
                              IOException

Records the status of a finished task from provisioner. Only the worker who currently owns the task can update the status.

Parameters:

finishRequest - Request to finish a task.

Throws:

MissingEntityException - if there is no provisioner for the provisioner id in the request.

IOException - if there was an error persisting task information.