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

Class TransportNodesHotThreadsAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.nodes.TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

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

public class TransportNodesHotThreadsAction
extends TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

Field Summary

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

clusterName, clusterService, transportService

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

actionName, threadPool

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

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportNodesHotThreadsAction(Settings settings, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method and Description
protected boolean	accumulateExceptions()
protected String	executor()
protected org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest	newNodeRequest()
protected org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest	newNodeRequest(String nodeId, NodesHotThreadsRequest request)
protected NodeHotThreads	newNodeResponse()
protected NodesHotThreadsRequest	newRequest()
protected NodesHotThreadsResponse	newResponse(NodesHotThreadsRequest request, AtomicReferenceArray responses)
protected NodeHotThreads	nodeOperation(org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest request)

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

doExecute, filterNodeIds, resolveNodes, transportCompress

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

execute, execute, forceThreadedListener

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

TransportNodesHotThreadsAction

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

Method Detail

executor

protected String executor()

Specified by:

executor in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newResponse

protected NodesHotThreadsResponse newResponse(NodesHotThreadsRequest request,
                                              AtomicReferenceArray responses)

Specified by:

newResponse in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newRequest

protected NodesHotThreadsRequest newRequest()

Specified by:

newRequest in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newNodeRequest

protected org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest newNodeRequest()

Specified by:

newNodeRequest in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newNodeRequest

protected org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest newNodeRequest(String nodeId,
                                                                                                                           NodesHotThreadsRequest request)

Specified by:

newNodeRequest in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newNodeResponse

protected NodeHotThreads newNodeResponse()

Specified by:

newNodeResponse in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

nodeOperation

protected NodeHotThreads nodeOperation(org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest request)
                                throws ElasticsearchException

Specified by:

nodeOperation in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

Throws:

ElasticsearchException

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>