public interface TaskRunner
TaskQueue
.Modifier and Type | Method and Description |
---|---|
Collection<? extends TaskRunnerWorkItem> |
getKnownTasks() |
Collection<? extends TaskRunnerWorkItem> |
getPendingTasks() |
Collection<? extends TaskRunnerWorkItem> |
getRunningTasks() |
com.google.common.base.Optional<ScalingStats> |
getScalingStats()
Some runners are able to scale up and down their capacity in a dynamic manner.
|
List<com.metamx.common.Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>> |
restore()
Some task runners can restart previously-running tasks after being bounced.
|
com.google.common.util.concurrent.ListenableFuture<TaskStatus> |
run(Task task)
Run a task.
|
void |
shutdown(String taskid)
Inform the task runner it can clean up any resources associated with a task.
|
void |
stop()
Stop this task runner.
|
List<com.metamx.common.Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>> restore()
com.google.common.util.concurrent.ListenableFuture<TaskStatus> run(Task task)
task
- task to runvoid shutdown(String taskid)
taskid
- task ID to clean up resources forvoid stop()
Collection<? extends TaskRunnerWorkItem> getRunningTasks()
Collection<? extends TaskRunnerWorkItem> getPendingTasks()
Collection<? extends TaskRunnerWorkItem> getKnownTasks()
com.google.common.base.Optional<ScalingStats> getScalingStats()
Copyright © 2011–2016. All rights reserved.