org.elasticsearch.action.support.single.shard
Class TransportShardSingleOperationAction<Request extends SingleShardOperationRequest,Response extends ActionResponse>

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

Direct Known Subclasses:

TransportExplainAction, TransportGetAction, TransportShardMultiGetAction

public abstract class TransportShardSingleOperationAction<Request extends SingleShardOperationRequest,Response extends ActionResponse>
extends TransportAction<Request,Response>

Nested Class Summary

protected class

TransportShardSingleOperationAction.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

TransportShardSingleOperationAction(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 void	resolveRequest(ClusterState state, Request request)
protected abstract Response	shardOperation(Request request, int shardId)
protected abstract ShardIterator	shards(ClusterState state, Request request)
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

TransportShardSingleOperationAction

protected TransportShardSingleOperationAction(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 SingleShardOperationRequest,Response extends ActionResponse>

transportAction

protected abstract String transportAction()

executor

protected abstract String executor()

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)

resolveRequest

protected void resolveRequest(ClusterState state,
                              Request request)

shards

protected abstract ShardIterator shards(ClusterState state,
                                        Request request)
                                 throws ElasticSearchException

Throws:

ElasticSearchException