Module org.elasticsearch.server
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
FieldsModifier and TypeFieldDescriptionprotected final ClusterServiceprotected final ExecutorThis is the amount of time given as the timeout for transport requests to the health node.protected final ThreadPoolprotected final TransportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, taskManager -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedTransportHealthNodeAction(String actionName, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters, Writeable.Reader<Request> request, Writeable.Reader<Response> response, Executor executor) -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddoExecute(Task task, Request request, ActionListener<Response> listener) protected abstract voidhealthOperation(Task task, Request request, ClusterState state, ActionListener<Response> listener) Methods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Field Details
-
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
-
clusterService
-
threadPool
-
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
- Specified by:
doExecutein classTransportAction<Request extends HealthNodeRequest,Response extends ActionResponse>
-