CompletionPersistentTaskAction.TransportAction
, DeletePipelineTransportAction
, PutPipelineTransportAction
, RemovePersistentTaskAction.TransportAction
, StartPersistentTaskAction.TransportAction
, TransportCloseIndexAction
, TransportClusterAllocationExplainAction
, TransportClusterRerouteAction
, TransportClusterUpdateSettingsAction
, TransportCreateIndexAction
, TransportCreateSnapshotAction
, TransportDeleteIndexAction
, TransportDeleteIndexTemplateAction
, TransportDeleteRepositoryAction
, TransportDeleteSnapshotAction
, TransportDeleteStoredScriptAction
, TransportGetSnapshotsAction
, TransportIndicesAliasesAction
, TransportMasterNodeReadAction
, TransportOpenIndexAction
, TransportPutIndexTemplateAction
, TransportPutMappingAction
, TransportPutRepositoryAction
, TransportPutStoredScriptAction
, TransportResizeAction
, TransportRestoreSnapshotAction
, TransportRolloverAction
, TransportSnapshotsStatusAction
, TransportUpdateSettingsAction
, TransportUpgradeSettingsAction
, TransportVerifyRepositoryAction
, UpdatePersistentTaskStatusAction.TransportAction
public abstract class TransportMasterNodeAction<Request extends MasterNodeRequest<Request>,Response extends ActionResponse> extends HandledTransportAction<Request,Response>
Modifier and Type | Field | Description |
---|---|---|
protected ClusterService |
clusterService |
|
protected TransportService |
transportService |
deprecationLogger, logger, settings
actionName, indexNameExpressionResolver, taskManager, threadPool
Modifier | Constructor | Description |
---|---|---|
protected |
TransportMasterNodeAction(Settings settings,
java.lang.String actionName,
boolean canTripCircuitBreaker,
TransportService transportService,
ClusterService clusterService,
ThreadPool threadPool,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver,
java.util.function.Supplier<Request> request) |
|
protected |
TransportMasterNodeAction(Settings settings,
java.lang.String actionName,
TransportService transportService,
ClusterService clusterService,
ThreadPool threadPool,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver,
java.util.function.Supplier<Request> request) |
Modifier and Type | Method | Description |
---|---|---|
protected abstract ClusterBlockException |
checkBlock(Request request,
ClusterState state) |
|
protected void |
doExecute(Task task,
Request request,
ActionListener<Response> listener) |
|
protected void |
doExecute(Request request,
ActionListener<Response> listener) |
|
protected abstract java.lang.String |
executor() |
|
protected java.lang.String |
getMasterActionName(DiscoveryNode node) |
Allows to conditionally return a different master node action name in the case an action gets renamed.
|
protected boolean |
localExecute(Request request) |
|
protected void |
masterOperation(Task task,
Request request,
ClusterState state,
ActionListener<Response> listener) |
Override this operation if access to the task parameter is needed
|
protected abstract void |
masterOperation(Request request,
ClusterState state,
ActionListener<Response> listener) |
|
protected abstract Response |
newResponse() |
logDeprecatedSetting, logRemovedSetting, nodeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execute, execute, execute, execute
protected final TransportService transportService
protected final ClusterService clusterService
protected TransportMasterNodeAction(Settings settings, java.lang.String actionName, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, java.util.function.Supplier<Request> request)
protected TransportMasterNodeAction(Settings settings, java.lang.String actionName, boolean canTripCircuitBreaker, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, java.util.function.Supplier<Request> request)
protected abstract java.lang.String executor()
protected abstract Response newResponse()
protected abstract void masterOperation(Request request, ClusterState state, ActionListener<Response> listener) throws java.lang.Exception
java.lang.Exception
protected void masterOperation(Task task, Request request, ClusterState state, ActionListener<Response> listener) throws java.lang.Exception
java.lang.Exception
protected boolean localExecute(Request request)
protected abstract ClusterBlockException checkBlock(Request request, ClusterState state)
protected final void doExecute(Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends MasterNodeRequest<Request>,Response extends ActionResponse>
protected void doExecute(Task task, Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends MasterNodeRequest<Request>,Response extends ActionResponse>
protected java.lang.String getMasterActionName(DiscoveryNode node)