public class TransportNodesRestartAction extends TransportNodesOperationAction<NodesRestartRequest,NodesRestartResponse,TransportNodesRestartAction.NodeRestartRequest,NodesRestartResponse.NodeRestartResponse>
Modifier and Type | Class and Description |
---|---|
protected static class |
TransportNodesRestartAction.NodeRestartRequest |
clusterName, clusterService, transportService
actionName, threadPool
componentSettings, logger, settings
Constructor and Description |
---|
TransportNodesRestartAction(Settings settings,
ClusterName clusterName,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
Node node,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
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) |
filterNodeIds, transportCompress
execute, execute, forceThreadedListener
nodeName
@Inject public TransportNodesRestartAction(Settings settings, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, Node node, ActionFilters actionFilters)
protected void doExecute(NodesRestartRequest nodesRestartRequest, ActionListener<NodesRestartResponse> listener)
protected String executor()
protected NodesRestartResponse newResponse(NodesRestartRequest nodesShutdownRequest, AtomicReferenceArray responses)
protected NodesRestartRequest newRequest()
protected TransportNodesRestartAction.NodeRestartRequest newNodeRequest()
protected TransportNodesRestartAction.NodeRestartRequest newNodeRequest(String nodeId, NodesRestartRequest request)
protected NodesRestartResponse.NodeRestartResponse newNodeResponse()
protected NodesRestartResponse.NodeRestartResponse nodeOperation(TransportNodesRestartAction.NodeRestartRequest request) throws ElasticsearchException
protected boolean accumulateExceptions()
Copyright © 2009–2015. All rights reserved.