org.elasticsearch.action.support.nodes
Class TransportNodesOperationAction<Request extends NodesOperationRequest,Response extends NodesOperationResponse,NodeRequest extends NodeOperationRequest,NodeResponse extends NodeOperationResponse>

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.nodes.TransportNodesOperationAction<Request,Response,NodeRequest,NodeResponse>

Direct Known Subclasses:

TransportNodesHotThreadsAction, TransportNodesInfoAction, TransportNodesListGatewayMetaState, TransportNodesListGatewayStartedShards, TransportNodesListShardStoreMetaData, TransportNodesRestartAction, TransportNodesStatsAction

public abstract class TransportNodesOperationAction<Request extends NodesOperationRequest,Response extends NodesOperationResponse,NodeRequest extends NodeOperationRequest,NodeResponse extends NodeOperationResponse>
extends TransportAction<Request,Response>

Field Summary

protected ClusterName	clusterName
protected ClusterService	clusterService
protected TransportService	transportService

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

threadPool

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

componentSettings, logger, settings

Constructor Summary

TransportNodesOperationAction(Settings settings, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService)

Method Summary

protected abstract boolean	accumulateExceptions()
protected void	doExecute(Request request, ActionListener<Response> listener)
protected abstract String	executor()
protected String[]	filterNodeIds(DiscoveryNodes nodes, String[] nodesIds)
protected abstract NodeRequest	newNodeRequest()
protected abstract NodeRequest	newNodeRequest(String nodeId, Request request)
protected abstract NodeResponse	newNodeResponse()
protected abstract Request	newRequest()
protected abstract Response	newResponse(Request request, AtomicReferenceArray nodesResponses)
protected abstract NodeResponse	nodeOperation(NodeRequest request)
protected abstract String	transportAction()
protected boolean	transportCompress()

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

execute, execute

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

nodeName

Methods inherited from class java.lang.Object

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

Field Detail

clusterName

protected final ClusterName clusterName

clusterService

protected final ClusterService clusterService

transportService

protected final TransportService transportService

Constructor Detail

TransportNodesOperationAction

@Inject
public TransportNodesOperationAction(Settings settings,
                                            ClusterName clusterName,
                                            ThreadPool threadPool,
                                            ClusterService clusterService,
                                            TransportService transportService)

Method Detail

doExecute

protected void doExecute(Request request,
                         ActionListener<Response> listener)

Specified by:

doExecute in class TransportAction<Request extends NodesOperationRequest,Response extends NodesOperationResponse>

transportAction

protected abstract String transportAction()

transportCompress

protected boolean transportCompress()

executor

protected abstract String executor()

newRequest

protected abstract Request newRequest()

newResponse

protected abstract Response newResponse(Request request,
                                        AtomicReferenceArray nodesResponses)

newNodeRequest

protected abstract NodeRequest newNodeRequest()

newNodeRequest

protected abstract NodeRequest newNodeRequest(String nodeId,
                                              Request request)

newNodeResponse

protected abstract NodeResponse newNodeResponse()

nodeOperation

protected abstract NodeResponse nodeOperation(NodeRequest request)
                                                                     throws ElasticSearchException

Throws:

ElasticSearchException

accumulateExceptions

protected abstract boolean accumulateExceptions()

filterNodeIds

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