org.elasticsearch.action.admin.cluster.node.restart
Class TransportNodesRestartAction

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.nodes.TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>
              org.elasticsearch.action.admin.cluster.node.restart.TransportNodesRestartAction

public class TransportNodesRestartAction
extends TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

Nested Class Summary

protected static class

TransportNodesRestartAction.NodeRestartRequest

Field Summary

Fields inherited from class org.elasticsearch.action.support.nodes.TransportNodesOperationAction

clusterName, clusterService, 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

TransportNodesRestartAction(Settings settings, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, Node node)

Method Summary

protected boolean	accumulateExceptions()
protected void	doExecute(NodesRestartRequest nodesRestartRequest, ActionListener<NodesRestartResponse> listener)
protected String	executor()
protected TransportNodesRestartAction.NodeRestartRequest	newNodeRequest()
protected TransportNodesRestartAction.NodeRestartRequest	newNodeRequest(String nodeId, NodesRestartRequest request)
protected NodesRestartResponse.NodeRestartResponse	newNodeResponse()
protected NodesRestartRequest	newRequest()
protected NodesRestartResponse	newResponse(NodesRestartRequest nodesShutdownRequest, AtomicReferenceArray responses)
protected NodesRestartResponse.NodeRestartResponse	nodeOperation(TransportNodesRestartAction.NodeRestartRequest request)
protected String	transportAction()

Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesOperationAction

filterNodeIds, 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

Constructor Detail

TransportNodesRestartAction

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

Method Detail

doExecute

protected void doExecute(NodesRestartRequest nodesRestartRequest,
                         ActionListener<NodesRestartResponse> listener)

Overrides:

doExecute in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

executor

protected String executor()

Specified by:

executor in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

transportAction

protected String transportAction()

Specified by:

transportAction in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

newResponse

protected NodesRestartResponse newResponse(NodesRestartRequest nodesShutdownRequest,
                                           AtomicReferenceArray responses)

Specified by:

newResponse in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

newRequest

protected NodesRestartRequest newRequest()

Specified by:

newRequest in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

newNodeRequest

protected TransportNodesRestartAction.NodeRestartRequest newNodeRequest()

Specified by:

newNodeRequest in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

newNodeRequest

protected TransportNodesRestartAction.NodeRestartRequest newNodeRequest(String nodeId,
                                                                        NodesRestartRequest request)

Specified by:

newNodeRequest in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

newNodeResponse

protected NodesRestartResponse.NodeRestartResponse newNodeResponse()

Specified by:

newNodeResponse in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

nodeOperation

protected NodesRestartResponse.NodeRestartResponse nodeOperation(TransportNodesRestartAction.NodeRestartRequest request)
                                                          throws ElasticSearchException

Specified by:

nodeOperation in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>

Throws:

ElasticSearchException

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>