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, TransportClusterRerouteAction, TransportClusterUpdateSettingsAction, TransportCreateIndexAction, TransportCreateSnapshotAction, TransportDeleteIndexAction, TransportDeleteIndexTemplateAction, TransportDeleteMappingAction, TransportDeleteRepositoryAction, TransportDeleteSnapshotAction, TransportDeleteWarmerAction, TransportGetSnapshotsAction, TransportIndicesAliasesAction, TransportMasterNodeReadOperationAction, TransportNodesShutdownAction, TransportOpenIndexAction, TransportPutIndexTemplateAction, TransportPutMappingAction, TransportPutRepositoryAction, TransportPutWarmerAction, TransportRestoreSnapshotAction, TransportSnapshotsStatusAction, TransportUpdateSettingsAction, TransportUpgradeSettingsAction, TransportVerifyRepositoryAction

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.

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterService	clusterService
protected TransportService	transportService

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName, threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TransportMasterNodeOperationAction(Settings settings, String actionName, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method and Description
protected abstract ClusterBlockException	checkBlock(Request request, ClusterState state)
protected void	doExecute(Request request, ActionListener<Response> listener)
protected abstract String	executor()
protected boolean	forceThreadedListener()
protected boolean	localExecute(Request request)
protected abstract void	masterOperation(Request request, ClusterState state, ActionListener<Response> listener)
protected abstract Request	newRequest()
protected abstract Response	newResponse()
protected void	processBeforeDelegationToMaster(Request request, ClusterState state)

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

transportService

protected final TransportService transportService

clusterService

protected final ClusterService clusterService

Constructor Detail

TransportMasterNodeOperationAction

protected TransportMasterNodeOperationAction(Settings settings,
                                             String actionName,
                                             TransportService transportService,
                                             ClusterService clusterService,
                                             ThreadPool threadPool,
                                             ActionFilters actionFilters)

Method Detail

executor

protected abstract String executor()

newRequest

protected abstract Request newRequest()

newResponse

protected abstract Response newResponse()

masterOperation

protected abstract void masterOperation(Request request,
                                        ClusterState state,
                                        ActionListener<Response> listener)
                                 throws ElasticsearchException

Throws:

ElasticsearchException

localExecute

protected boolean localExecute(Request request)

checkBlock

protected abstract ClusterBlockException checkBlock(Request request,
                                                    ClusterState state)

processBeforeDelegationToMaster

protected void processBeforeDelegationToMaster(Request request,
                                               ClusterState state)

forceThreadedListener

protected boolean forceThreadedListener()

Overrides:

forceThreadedListener in class TransportAction<Request extends MasterNodeOperationRequest,Response extends ActionResponse>

doExecute

protected void doExecute(Request request,
                         ActionListener<Response> listener)

Specified by:

doExecute in class TransportAction<Request extends MasterNodeOperationRequest,Response extends ActionResponse>