public abstract class TransportMasterNodeOperationAction<Request extends MasterNodeOperationRequest,Response extends ActionResponse> extends TransportAction<Request,Response>
Modifier and Type | Field and Description |
---|---|
protected ClusterService |
clusterService |
protected TransportService |
transportService |
actionName, threadPool
componentSettings, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportMasterNodeOperationAction(Settings settings,
String actionName,
TransportService transportService,
ClusterService clusterService,
ThreadPool threadPool,
ActionFilters actionFilters) |
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) |
execute, execute
nodeName
protected final TransportService transportService
protected final ClusterService clusterService
protected TransportMasterNodeOperationAction(Settings settings, String actionName, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, ActionFilters actionFilters)
protected abstract String executor()
protected abstract Request newRequest()
protected abstract Response newResponse()
protected abstract void masterOperation(Request request, ClusterState state, ActionListener<Response> listener) throws ElasticsearchException
ElasticsearchException
protected boolean localExecute(Request request)
protected abstract ClusterBlockException checkBlock(Request request, ClusterState state)
protected void processBeforeDelegationToMaster(Request request, ClusterState state)
protected boolean forceThreadedListener()
forceThreadedListener
in class TransportAction<Request extends MasterNodeOperationRequest,Response extends ActionResponse>
protected void doExecute(Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends MasterNodeOperationRequest,Response extends ActionResponse>
Copyright © 2009–2015. All rights reserved.