Package org.elasticsearch.index.reindex

Class TransportRethrottleAction

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<org.elasticsearch.index.reindex.BulkByScrollTask,RethrottleRequest,org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse,org.elasticsearch.tasks.TaskInfo>

org.elasticsearch.index.reindex.TransportRethrottleAction

public class TransportRethrottleAction
extends org.elasticsearch.action.support.tasks.TransportTasksAction<org.elasticsearch.index.reindex.BulkByScrollTask,RethrottleRequest,org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse,org.elasticsearch.tasks.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

TransportRethrottleAction(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.cluster.service.ClusterService clusterService, org.elasticsearch.transport.TransportService transportService, org.elasticsearch.action.support.ActionFilters actionFilters, org.elasticsearch.cluster.metadata.IndexNameExpressionResolver indexNameExpressionResolver, org.elasticsearch.client.Client client)

Method Summary

Modifier and Type	Method	Description
protected org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse	newResponse(RethrottleRequest request, java.util.List<org.elasticsearch.tasks.TaskInfo> tasks, java.util.List<org.elasticsearch.action.TaskOperationFailure> taskOperationFailures, java.util.List<org.elasticsearch.action.FailedNodeException> failedNodeExceptions)
protected org.elasticsearch.tasks.TaskInfo	readTaskResponse(org.elasticsearch.common.io.stream.StreamInput in)
protected void	taskOperation(RethrottleRequest request, org.elasticsearch.index.reindex.BulkByScrollTask task, org.elasticsearch.action.ActionListener<org.elasticsearch.tasks.TaskInfo> listener)

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, processTasks, resolveNodes, transportCompress

Constructor Detail

TransportRethrottleAction

@Inject
public TransportRethrottleAction(org.elasticsearch.common.settings.Settings settings,
                                 org.elasticsearch.threadpool.ThreadPool threadPool,
                                 org.elasticsearch.cluster.service.ClusterService clusterService,
                                 org.elasticsearch.transport.TransportService transportService,
                                 org.elasticsearch.action.support.ActionFilters actionFilters,
                                 org.elasticsearch.cluster.metadata.IndexNameExpressionResolver indexNameExpressionResolver,
                                 org.elasticsearch.client.Client client)

Method Detail

taskOperation

protected void taskOperation(RethrottleRequest request,
                             org.elasticsearch.index.reindex.BulkByScrollTask task,
                             org.elasticsearch.action.ActionListener<org.elasticsearch.tasks.TaskInfo> listener)

Specified by:

taskOperation in class org.elasticsearch.action.support.tasks.TransportTasksAction<org.elasticsearch.index.reindex.BulkByScrollTask,RethrottleRequest,org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse,org.elasticsearch.tasks.TaskInfo>

readTaskResponse

protected org.elasticsearch.tasks.TaskInfo readTaskResponse(org.elasticsearch.common.io.stream.StreamInput in)
                                                     throws java.io.IOException

Specified by:

readTaskResponse in class org.elasticsearch.action.support.tasks.TransportTasksAction<org.elasticsearch.index.reindex.BulkByScrollTask,RethrottleRequest,org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse,org.elasticsearch.tasks.TaskInfo>

Throws:

java.io.IOException

newResponse

protected org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse newResponse(RethrottleRequest request,
                                                                                               java.util.List<org.elasticsearch.tasks.TaskInfo> tasks,
                                                                                               java.util.List<org.elasticsearch.action.TaskOperationFailure> taskOperationFailures,
                                                                                               java.util.List<org.elasticsearch.action.FailedNodeException> failedNodeExceptions)

Specified by:

newResponse in class org.elasticsearch.action.support.tasks.TransportTasksAction<org.elasticsearch.index.reindex.BulkByScrollTask,RethrottleRequest,org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse,org.elasticsearch.tasks.TaskInfo>