Package org.elasticsearch.action.admin.cluster.node.tasks.list

Class TransportListTasksAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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.common.component.AbstractComponent

deprecationLogger, logger, settings

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName, indexNameExpressionResolver, taskManager, threadPool

Fields inherited from class org.elasticsearch.action.support.tasks.TransportTasksAction

clusterService, requestSupplier, responseSupplier, transportNodeAction, transportService

Constructor Summary

Constructors

Constructor	Description
TransportListTasksAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)

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 TaskInfo	readTaskResponse(StreamInput in)
protected void	taskOperation(ListTasksRequest request, Task task, ActionListener<TaskInfo> listener)	Perform the required operation on the task.
static long	waitForCompletionTimeout(TimeValue timeout)

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute, execute, execute

Methods inherited from class org.elasticsearch.action.support.tasks.TransportTasksAction

doExecute, doExecute, filterNodeIds, newResponse, resolveNodes, transportCompress

Constructor Detail

TransportListTasksAction

@Inject
public TransportListTasksAction(Settings settings,
                                ThreadPool threadPool,
                                ClusterService clusterService,
                                TransportService transportService,
                                ActionFilters actionFilters,
                                IndexNameExpressionResolver indexNameExpressionResolver)

Method Detail

waitForCompletionTimeout

public static long waitForCompletionTimeout(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 class TransportTasksAction<Task,ListTasksRequest,ListTasksResponse,TaskInfo>

readTaskResponse

protected TaskInfo readTaskResponse(StreamInput in)
                             throws java.io.IOException

Specified by:

readTaskResponse in class TransportTasksAction<Task,ListTasksRequest,ListTasksResponse,TaskInfo>

Throws:

java.io.IOException

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 class TransportTasksAction<Task,ListTasksRequest,ListTasksResponse,TaskInfo>

processTasks

protected void processTasks(ListTasksRequest request,
                            java.util.function.Consumer<Task> operation)

Overrides:

processTasks in class TransportTasksAction<Task,ListTasksRequest,ListTasksResponse,TaskInfo>