Module org.elasticsearch.server
Class TransportMasterNodeAction<Request extends MasterNodeRequest<Request>,Response extends ActionResponse>
java.lang.Object
org.elasticsearch.action.support.TransportAction<Request,Response>
org.elasticsearch.action.support.HandledTransportAction<Request,Response>
org.elasticsearch.action.support.master.TransportMasterNodeAction<Request,Response>
- All Implemented Interfaces:
ActionWithReservedState<Request>
- Direct Known Subclasses:
AcknowledgedTransportMasterNodeAction,AutoCreateAction.TransportAction,CompletionPersistentTaskAction.TransportAction,RemovePersistentTaskAction.TransportAction,StartPersistentTaskAction.TransportAction,TransportAddIndexBlockAction,TransportAddVotingConfigExclusionsAction,TransportCleanupRepositoryAction,TransportClearVotingConfigExclusionsAction,TransportCloseIndexAction,TransportClusterAllocationExplainAction,TransportClusterRerouteAction,TransportClusterUpdateSettingsAction,TransportCreateIndexAction,TransportCreateSnapshotAction,TransportDeleteDesiredBalanceAction,TransportDeleteDesiredNodesAction,TransportGetShardSnapshotAction,TransportGetSnapshotsAction,TransportIndicesAliasesAction,TransportMasterNodeReadAction,TransportOpenIndexAction,TransportResetFeatureStateAction,TransportResizeAction,TransportRestoreSnapshotAction,TransportRolloverAction,TransportSnapshotsStatusAction,TransportSnapshottableFeaturesAction,TransportUpdateDesiredNodesAction,TransportVerifyRepositoryAction,UpdatePersistentTaskStatusAction.TransportAction
public abstract class TransportMasterNodeAction<Request extends MasterNodeRequest<Request>,Response extends ActionResponse>
extends HandledTransportAction<Request,Response>
implements ActionWithReservedState<Request>
A base class for operations that needs to be performed on the master node.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final ClusterServiceprotected final Executorprotected final ThreadPoolprotected final TransportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, taskManager -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedTransportMasterNodeAction(String actionName, boolean canTripCircuitBreaker, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters, Writeable.Reader<Request> request, Writeable.Reader<Response> response, Executor executor) protectedTransportMasterNodeAction(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 abstract ClusterBlockExceptioncheckBlock(Request request, ClusterState state) protected voiddoExecute(Task task, Request request, ActionListener<Response> listener) protected booleanlocalExecute(Request request) protected abstract voidmasterOperation(Task task, Request request, ClusterState state, ActionListener<Response> listener) Methods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnlyMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.reservedstate.ActionWithReservedState
modifiedKeys, reservedStateHandlerName, validateForReservedState
-
Field Details
-
threadPool
-
transportService
-
clusterService
-
executor
-
-
Constructor Details
-
TransportMasterNodeAction
protected TransportMasterNodeAction(String actionName, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters, Writeable.Reader<Request> request, Writeable.Reader<Response> response, Executor executor) -
TransportMasterNodeAction
protected TransportMasterNodeAction(String actionName, boolean canTripCircuitBreaker, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters, Writeable.Reader<Request> request, Writeable.Reader<Response> response, Executor executor)
-
-
Method Details
-
masterOperation
protected abstract void masterOperation(Task task, Request request, ClusterState state, ActionListener<Response> listener) throws Exception - Throws:
Exception
-
localExecute
-
checkBlock
-
doExecute
- Specified by:
doExecutein classTransportAction<Request extends MasterNodeRequest<Request>,Response extends ActionResponse>
-