org.elasticsearch.action.support.single.custom
Class TransportSingleCustomOperationAction<Request extends SingleCustomOperationRequest,Response extends ActionResponse>

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.single.custom.TransportSingleCustomOperationAction<Request,Response>

Direct Known Subclasses:

TransportAnalyzeAction, TransportPercolateAction

public abstract class TransportSingleCustomOperationAction<Request extends SingleCustomOperationRequest,Response extends ActionResponse>
extends TransportAction<Request,Response>

Nested Class Summary

protected class

TransportSingleCustomOperationAction.ShardSingleOperationRequest

Field Summary

protected ClusterService	clusterService
protected TransportService	transportService

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

threadPool

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

componentSettings, logger, settings

Constructor Summary

protected

TransportSingleCustomOperationAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService)

Method Summary

protected abstract ClusterBlockException	checkGlobalBlock(ClusterState state, Request request)
protected abstract ClusterBlockException	checkRequestBlock(ClusterState state, Request request)
protected void	doExecute(Request request, ActionListener<Response> listener)
protected abstract String	executor()
protected abstract Request	newRequest()
protected abstract Response	newResponse()
protected abstract Response	shardOperation(Request request, int shardId)
protected abstract ShardsIterator	shards(ClusterState state, Request request) Can return null to execute on this local node.
protected abstract String	transportAction()

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

clusterService

protected final ClusterService clusterService

transportService

protected final TransportService transportService

Constructor Detail

TransportSingleCustomOperationAction

protected TransportSingleCustomOperationAction(Settings settings,
                                               ThreadPool threadPool,
                                               ClusterService clusterService,
                                               TransportService transportService)

Method Detail

doExecute

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

Specified by:

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

transportAction

protected abstract String transportAction()

executor

protected abstract String executor()

shards

protected abstract ShardsIterator shards(ClusterState state,
                                         Request request)

Can return null to execute on this local node.

shardOperation

protected abstract Response shardOperation(Request request,
                                           int shardId)
                                                           throws ElasticSearchException

Throws:

ElasticSearchException

newRequest

protected abstract Request newRequest()

newResponse

protected abstract Response newResponse()

checkGlobalBlock

protected abstract ClusterBlockException checkGlobalBlock(ClusterState state,
                                                          Request request)

checkRequestBlock

protected abstract ClusterBlockException checkRequestBlock(ClusterState state,
                                                           Request request)