Package org.elasticsearch.action.admin.cluster.node.hotthreads

Class TransportNodesHotThreadsAction

java.lang.Object

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

org.elasticsearch.action.support.HandledTransportAction<NodesRequest,NodesResponse>

org.elasticsearch.action.support.nodes.TransportNodesAction<NodesHotThreadsRequest,NodesHotThreadsResponse,TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction

public class TransportNodesHotThreadsAction
extends TransportNodesAction<NodesHotThreadsRequest,NodesHotThreadsResponse,TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransportNodesHotThreadsAction.NodeRequest

Field Summary

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

clusterService, nodeResponseClass, threadPool, transportNodeAction, transportService

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

actionName, localConnection, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportNodesHotThreadsAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method	Description
protected TransportNodesHotThreadsAction.NodeRequest	newNodeRequest(NodesHotThreadsRequest request)
protected NodeHotThreads	newNodeResponse(StreamInput in)
protected NodesHotThreadsResponse	newResponse(NodesHotThreadsRequest request, List<NodeHotThreads> responses, List<FailedNodeException> failures)	Create a new TransportNodesAction (multi-node response).
protected NodeHotThreads	nodeOperation(TransportNodesHotThreadsAction.NodeRequest request)

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

doExecute, getTransportNodeAction, newResponseAsync, nodeOperation, resolveRequest

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

Constructor Details

TransportNodesHotThreadsAction

@Inject
public TransportNodesHotThreadsAction(ThreadPool threadPool,
 ClusterService clusterService,
 TransportService transportService,
 ActionFilters actionFilters)

Method Details

newResponse

protected NodesHotThreadsResponse newResponse(NodesHotThreadsRequest request,
 List<NodeHotThreads> responses,
 List<FailedNodeException> failures)

Description copied from class: TransportNodesAction

Create a new TransportNodesAction (multi-node response).

Specified by:

newResponse in class TransportNodesAction<NodesHotThreadsRequest,NodesHotThreadsResponse,TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

Parameters:

request - The associated request.

responses - All successful node-level responses.

failures - All node-level failures.

Returns:

Never null.

newNodeRequest

protected TransportNodesHotThreadsAction.NodeRequest newNodeRequest(NodesHotThreadsRequest request)

Specified by:

newNodeRequest in class TransportNodesAction<NodesHotThreadsRequest,NodesHotThreadsResponse,TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newNodeResponse

protected NodeHotThreads newNodeResponse(StreamInput in)
                                  throws IOException

Specified by:

newNodeResponse in class TransportNodesAction<NodesHotThreadsRequest,NodesHotThreadsResponse,TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

Throws:

IOException

nodeOperation

protected NodeHotThreads nodeOperation(TransportNodesHotThreadsAction.NodeRequest request)

Specified by:

nodeOperation in class TransportNodesAction<NodesHotThreadsRequest,NodesHotThreadsResponse,TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>