Class TransportListTasksAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<Request,Response>
org.elasticsearch.action.support.HandledTransportAction<TasksRequest,TasksResponse>
org.elasticsearch.action.support.tasks.TransportTasksAction<Task,ListTasksRequest,ListTasksResponse,TaskInfo>
org.elasticsearch.action.admin.cluster.node.tasks.list.TransportListTasksAction
public class TransportListTasksAction extends TransportTasksAction<Task,ListTasksRequest,ListTasksResponse,TaskInfo>
-
Field Summary
Fields inherited from class org.elasticsearch.action.support.tasks.TransportTasksAction
clusterService, requestReader, responseReader, responsesReader, transportNodeAction, transportService
Fields inherited from class org.elasticsearch.action.support.TransportAction
actionName, localConnection, logger, taskManager
-
Constructor Summary
Constructors Constructor Description TransportListTasksAction(ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)
-
Method Summary
Modifier and Type Method Description protected ListTasksResponse
newResponse(ListTasksRequest request, java.util.List<TaskInfo> tasks, java.util.List<TaskOperationFailure> taskOperationFailures, java.util.List<FailedNodeException> failedNodeExceptions)
protected void
processTasks(ListTasksRequest request, java.util.function.Consumer<Task> operation)
protected void
taskOperation(ListTasksRequest request, Task task, ActionListener<TaskInfo> listener)
Perform the required operation on the task.static long
waitForCompletionTimeout(org.elasticsearch.common.unit.TimeValue timeout)
Methods inherited from class org.elasticsearch.action.support.tasks.TransportTasksAction
doExecute, filterNodeIds, newResponse, resolveNodes
Methods inherited from class org.elasticsearch.action.support.TransportAction
execute, execute, execute
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
TransportListTasksAction
@Inject public TransportListTasksAction(ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)
-
-
Method Details
-
waitForCompletionTimeout
public static long waitForCompletionTimeout(org.elasticsearch.common.unit.TimeValue timeout) -
newResponse
protected ListTasksResponse newResponse(ListTasksRequest request, java.util.List<TaskInfo> tasks, java.util.List<TaskOperationFailure> taskOperationFailures, java.util.List<FailedNodeException> failedNodeExceptions)- Specified by:
newResponse
in classTransportTasksAction<Task,ListTasksRequest,ListTasksResponse,TaskInfo>
-
taskOperation
protected void taskOperation(ListTasksRequest request, Task task, ActionListener<TaskInfo> listener)Description copied from class:TransportTasksAction
Perform the required operation on the task. It is OK start an asynchronous operation or to throw an exception but not both.- Specified by:
taskOperation
in classTransportTasksAction<Task,ListTasksRequest,ListTasksResponse,TaskInfo>
-
processTasks
- Overrides:
processTasks
in classTransportTasksAction<Task,ListTasksRequest,ListTasksResponse,TaskInfo>
-