org.elasticsearch.action.support.replication
Class TransportIndicesReplicationOperationAction<Request extends IndicesReplicationOperationRequest,Response extends ActionResponse,IndexRequest extends IndexReplicationOperationRequest,IndexResponse extends ActionResponse,ShardRequest extends ShardReplicationOperationRequest,ShardReplicaRequest extends ActionRequest,ShardResponse extends ActionResponse>

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.replication.TransportIndicesReplicationOperationAction<Request,Response,IndexRequest,IndexResponse,ShardRequest,ShardReplicaRequest,ShardResponse>

Direct Known Subclasses:

TransportDeleteByQueryAction

public abstract class TransportIndicesReplicationOperationAction<Request extends IndicesReplicationOperationRequest,Response extends ActionResponse,IndexRequest extends IndexReplicationOperationRequest,IndexResponse extends ActionResponse,ShardRequest extends ShardReplicationOperationRequest,ShardReplicaRequest extends ActionRequest,ShardResponse extends ActionResponse>
extends TransportAction<Request,Response>

Field Summary

protected ClusterService	clusterService
protected TransportIndexReplicationOperationAction<IndexRequest,IndexResponse,ShardRequest,ShardReplicaRequest,ShardResponse>	indexAction

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

threadPool

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

componentSettings, logger, settings

Constructor Summary

TransportIndicesReplicationOperationAction(Settings settings, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, TransportIndexReplicationOperationAction<IndexRequest,IndexResponse,ShardRequest,ShardReplicaRequest,ShardResponse> indexAction)

Method Summary

protected abstract boolean	accumulateExceptions()
protected abstract ClusterBlockException	checkGlobalBlock(ClusterState state, Request request)
protected abstract ClusterBlockException	checkRequestBlock(ClusterState state, Request request, String[] concreteIndices)
protected void	doExecute(Request request, ActionListener<Response> listener)
protected abstract IndexRequest	newIndexRequestInstance(Request request, String index, Set<String> routing)
protected abstract Request	newRequestInstance()
protected abstract Response	newResponseInstance(Request request, AtomicReferenceArray indexResponses)
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

indexAction

protected final TransportIndexReplicationOperationAction<IndexRequest extends IndexReplicationOperationRequest,IndexResponse extends ActionResponse,ShardRequest extends ShardReplicationOperationRequest,ShardReplicaRequest extends ActionRequest,ShardResponse extends ActionResponse> indexAction

Constructor Detail

TransportIndicesReplicationOperationAction

@Inject
public TransportIndicesReplicationOperationAction(Settings settings,
                                                         TransportService transportService,
                                                         ClusterService clusterService,
                                                         ThreadPool threadPool,
                                                         TransportIndexReplicationOperationAction<IndexRequest,IndexResponse,ShardRequest,ShardReplicaRequest,ShardResponse> indexAction)

Method Detail

doExecute

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

Specified by:

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

newRequestInstance

protected abstract Request newRequestInstance()

newResponseInstance

protected abstract Response newResponseInstance(Request request,
                                                AtomicReferenceArray indexResponses)

transportAction

protected abstract String transportAction()

newIndexRequestInstance

protected abstract IndexRequest newIndexRequestInstance(Request request,
                                                        String index,
                                                        Set<String> routing)

accumulateExceptions

protected abstract boolean accumulateExceptions()

checkGlobalBlock

protected abstract ClusterBlockException checkGlobalBlock(ClusterState state,
                                                          Request request)

checkRequestBlock

protected abstract ClusterBlockException checkRequestBlock(ClusterState state,
                                                           Request request,
                                                           String[] concreteIndices)