Module org.elasticsearch.server

Package org.elasticsearch.health.node.action

Class TransportHealthNodeAction<Request extends HealthNodeRequest,Response extends ActionResponse>

java.lang.Object

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

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

org.elasticsearch.health.node.action.TransportHealthNodeAction<Request,Response>

Direct Known Subclasses:

FetchHealthInfoCacheAction.TransportAction, UpdateHealthInfoCacheAction.TransportAction

public abstract class TransportHealthNodeAction<Request extends HealthNodeRequest,Response extends ActionResponse>
extends HandledTransportAction<Request,Response>

A base class for operations that need to be performed on the health node.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ClusterService	clusterService
protected final Executor	executor
static final Setting<TimeValue>	HEALTH_NODE_TRANSPORT_ACTION_TIMEOUT	This is the amount of time given as the timeout for transport requests to the health node.
protected final ThreadPool	threadPool
protected final TransportService	transportService

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

actionName, taskManager

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TransportHealthNodeAction(String actionName, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters, Writeable.Reader<Request> request, Writeable.Reader<Response> response, Executor executor)

Method Summary

Modifier and Type	Method	Description
protected void	doExecute(Task task, Request request, ActionListener<Response> listener)
protected abstract void	healthOperation(Task task, Request request, ClusterState state, ActionListener<Response> listener)

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

execute, localOnly

Methods inherited from class java.lang.Object

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

Field Details

HEALTH_NODE_TRANSPORT_ACTION_TIMEOUT

public static final Setting<TimeValue> HEALTH_NODE_TRANSPORT_ACTION_TIMEOUT

This is the amount of time given as the timeout for transport requests to the health node. The default is fairly low because these actions are expected to be lightweight and time-sensitive.

transportService

protected final TransportService transportService

clusterService

protected final ClusterService clusterService

threadPool

protected final ThreadPool threadPool

executor

protected final Executor executor

Constructor Details

TransportHealthNodeAction

protected TransportHealthNodeAction(String actionName,
 TransportService transportService,
 ClusterService clusterService,
 ThreadPool threadPool,
 ActionFilters actionFilters,
 Writeable.Reader<Request> request,
 Writeable.Reader<Response> response,
 Executor executor)

Method Details

healthOperation

protected abstract void healthOperation(Task task,
 Request request,
 ClusterState state,
 ActionListener<Response> listener)
                                 throws Exception

Throws:

Exception

doExecute

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

Specified by:

doExecute in class TransportAction<Request extends HealthNodeRequest,Response extends ActionResponse>