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,TransportRemoveIndexBlockAction,TransportResetFeatureStateAction,TransportResizeAction,TransportRestoreSnapshotAction,TransportRolloverAction,TransportSnapshotsStatusAction,TransportSnapshottableFeaturesAction,TransportUpdateDesiredNodesAction,TransportUpdateSnapshotStatusAction,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) protected voidvalidateForReservedState(Request request, ClusterState state) 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
-
validateForReservedState
-
doExecute
- Specified by:
doExecutein classTransportAction<Request extends MasterNodeRequest<Request>,Response extends ActionResponse>
-