org.elasticsearch.action.support.master
Class TransportMasterNodeOperationAction<Request extends MasterNodeOperationRequest,Response extends ActionResponse>
java.lang.Object
org.elasticsearch.common.component.AbstractComponent
org.elasticsearch.action.support.TransportAction<Request,Response>
org.elasticsearch.action.support.master.TransportMasterNodeOperationAction<Request,Response>
- Direct Known Subclasses:
- MappingUpdatedAction, TransportCloseIndexAction, TransportClusterHealthAction, TransportClusterRerouteAction, TransportClusterStateAction, TransportClusterUpdateSettingsAction, TransportCreateIndexAction, TransportDeleteIndexAction, TransportDeleteIndexTemplateAction, TransportDeleteMappingAction, TransportDeleteWarmerAction, TransportIndicesAliasesAction, TransportIndicesExistsAction, TransportNodesShutdownAction, TransportOpenIndexAction, TransportPutIndexTemplateAction, TransportPutMappingAction, TransportPutWarmerAction, TransportUpdateSettingsAction
public abstract class TransportMasterNodeOperationAction<Request extends MasterNodeOperationRequest,Response extends ActionResponse>
- extends TransportAction<Request,Response>
A base class for operations that needs to be performed on the master node.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
transportService
protected final TransportService transportService
clusterService
protected final ClusterService clusterService
TransportMasterNodeOperationAction
protected TransportMasterNodeOperationAction(Settings settings,
TransportService transportService,
ClusterService clusterService,
ThreadPool threadPool)
transportAction
protected abstract String transportAction()
executor
protected abstract String executor()
newRequest
protected abstract Request newRequest()
newResponse
protected abstract Response newResponse()
masterOperation
protected abstract Response masterOperation(Request request,
ClusterState state)
throws ElasticSearchException
- Throws:
ElasticSearchException
localExecute
protected boolean localExecute(Request request)
checkBlock
protected ClusterBlockException checkBlock(Request request,
ClusterState state)
processBeforeDelegationToMaster
protected void processBeforeDelegationToMaster(Request request,
ClusterState state)
doExecute
protected void doExecute(Request request,
ActionListener<Response> listener)
- Specified by:
doExecute
in class TransportAction<Request extends MasterNodeOperationRequest,Response extends ActionResponse>
Copyright © 2009-2012. All Rights Reserved.