Module org.elasticsearch.server
Class TransportListTasksAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<ListTasksRequest,ListTasksResponse>
org.elasticsearch.action.support.HandledTransportAction<ListTasksRequest,ListTasksResponse>
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
FieldsFields inherited from class org.elasticsearch.action.support.tasks.TransportTasksAction
clusterService, requestReader, responseReader, transportNodeAction, transportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, logger, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportListTasksAction(ClusterService clusterService, TransportService transportService, ActionFilters actionFilters) -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddoExecute(Task task, ListTasksRequest request, ActionListener<ListTasksResponse> listener) protected ListTasksResponsenewResponse(ListTasksRequest request, List<TaskInfo> tasks, List<TaskOperationFailure> taskOperationFailures, List<FailedNodeException> failedNodeExceptions) protected voidprocessTasks(CancellableTask nodeTask, ListTasksRequest request, ActionListener<List<Task>> nodeOperation) protected voidtaskOperation(CancellableTask actionTask, ListTasksRequest request, Task task, ActionListener<TaskInfo> listener) Perform the required operation on the task.static longwaitForCompletionTimeout(TimeValue timeout) Methods inherited from class org.elasticsearch.action.support.tasks.TransportTasksAction
processTasks, resolveNodesMethods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Field Details
-
TYPE
-
-
Constructor Details
-
TransportListTasksAction
@Inject public TransportListTasksAction(ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)
-
-
Method Details
-
waitForCompletionTimeout
-
newResponse
protected ListTasksResponse newResponse(ListTasksRequest request, List<TaskInfo> tasks, List<TaskOperationFailure> taskOperationFailures, List<FailedNodeException> failedNodeExceptions) - Specified by:
newResponsein classTransportTasksAction<Task,ListTasksRequest, ListTasksResponse, TaskInfo>
-
taskOperation
protected void taskOperation(CancellableTask actionTask, ListTasksRequest request, Task task, ActionListener<TaskInfo> listener) Description copied from class:TransportTasksActionPerform the required operation on the task. It is OK start an asynchronous operation or to throw an exception but not both.- Specified by:
taskOperationin classTransportTasksAction<Task,ListTasksRequest, ListTasksResponse, TaskInfo> - Parameters:
actionTask- The related transport action task. Can be used to create a task ID to handle upstream transport cancellations.request- the original transport requesttask- the task on which the operation is taking placelistener- the listener to signal.
-
doExecute
protected void doExecute(Task task, ListTasksRequest request, ActionListener<ListTasksResponse> listener) - Overrides:
doExecutein classTransportTasksAction<Task,ListTasksRequest, ListTasksResponse, TaskInfo>
-
processTasks
protected void processTasks(CancellableTask nodeTask, ListTasksRequest request, ActionListener<List<Task>> nodeOperation) - Overrides:
processTasksin classTransportTasksAction<Task,ListTasksRequest, ListTasksResponse, TaskInfo>
-