Package org.elasticsearch.action.support.tasks

Class TransportTasksAction<OperationTask extends Task,TasksRequest extends BaseTasksRequest<TasksRequest>,TasksResponse extends BaseTasksResponse,TaskResponse extends Writeable>

java.lang.Object

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.HandledTransportAction<TasksRequest,TasksResponse>

org.elasticsearch.action.support.tasks.TransportTasksAction<OperationTask,TasksRequest,TasksResponse,TaskResponse>

Direct Known Subclasses:

TransportCancelTasksAction, TransportListTasksAction

public abstract class TransportTasksAction<OperationTask extends Task,TasksRequest extends BaseTasksRequest<TasksRequest>,TasksResponse extends BaseTasksResponse,TaskResponse extends Writeable>
extends HandledTransportAction<TasksRequest,TasksResponse>

The base class for transport actions that are interacting with currently running tasks.

Field Summary

Fields

Modifier and Type	Field	Description
protected ClusterService	clusterService
protected Writeable.Reader<TasksRequest>	requestReader
protected Writeable.Reader<TaskResponse>	responseReader
protected Writeable.Reader<TasksResponse>	responsesReader
protected String	transportNodeAction
protected TransportService	transportService

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

actionName, localConnection, logger, taskManager

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TransportTasksAction(String actionName, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, Writeable.Reader<TasksRequest> requestReader, Writeable.Reader<TasksResponse> responsesReader, Writeable.Reader<TaskResponse> responseReader, String nodeExecutor)

Method Summary

Modifier and Type	Method	Description
protected void	doExecute(Task task, TasksRequest request, ActionListener<TasksResponse> listener)
protected String[]	filterNodeIds(DiscoveryNodes nodes, String[] nodesIds)
protected TasksResponse	newResponse(TasksRequest request, AtomicReferenceArray responses)
protected abstract TasksResponse	newResponse(TasksRequest request, List<TaskResponse> tasks, List<TaskOperationFailure> taskOperationFailures, List<FailedNodeException> failedNodeExceptions)
protected void	processTasks(TasksRequest request, Consumer<OperationTask> operation)
protected String[]	resolveNodes(TasksRequest request, ClusterState clusterState)
protected abstract void	taskOperation(TasksRequest request, OperationTask task, ActionListener<TaskResponse> listener)	Perform the required operation on the task.

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

Field Details

clusterService

protected final ClusterService clusterService

transportService

protected final TransportService transportService

requestReader

protected final Writeable.Reader<TasksRequest extends BaseTasksRequest<TasksRequest>> requestReader

responsesReader

protected final Writeable.Reader<TasksResponse extends BaseTasksResponse> responsesReader

responseReader

protected final Writeable.Reader<TaskResponse extends Writeable> responseReader

transportNodeAction

protected final String transportNodeAction

Constructor Details

TransportTasksAction

protected TransportTasksAction(String actionName,
 ClusterService clusterService,
 TransportService transportService,
 ActionFilters actionFilters,
 Writeable.Reader<TasksRequest> requestReader,
 Writeable.Reader<TasksResponse> responsesReader,
 Writeable.Reader<TaskResponse> responseReader,
 String nodeExecutor)

Method Details

doExecute

protected void doExecute(Task task,
 TasksRequest request,
 ActionListener<TasksResponse> listener)

Specified by:

doExecute in class TransportAction<TasksRequest extends BaseTasksRequest<TasksRequest>,TasksResponse extends BaseTasksResponse>

filterNodeIds

protected String[] filterNodeIds(DiscoveryNodes nodes,
 String[] nodesIds)

resolveNodes

protected String[] resolveNodes(TasksRequest request,
 ClusterState clusterState)

processTasks

protected void processTasks(TasksRequest request,
 Consumer<OperationTask> operation)

newResponse

protected abstract TasksResponse newResponse(TasksRequest request,
 List<TaskResponse> tasks,
 List<TaskOperationFailure> taskOperationFailures,
 List<FailedNodeException> failedNodeExceptions)

newResponse

protected TasksResponse newResponse(TasksRequest request,
 AtomicReferenceArray responses)

taskOperation

protected abstract void taskOperation(TasksRequest request,
 OperationTask task,
 ActionListener<TaskResponse> listener)

Perform the required operation on the task. It is OK start an asynchronous operation or to throw an exception but not both.