org.elasticsearch.action.delete.index
Class TransportIndexDeleteAction

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.replication.TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>
              org.elasticsearch.action.delete.index.TransportIndexDeleteAction

public class TransportIndexDeleteAction
extends TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

Field Summary

Fields inherited from class org.elasticsearch.action.support.replication.TransportIndexReplicationOperationAction

clusterService, shardAction

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

threadPool

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

componentSettings, logger, settings

Constructor Summary

TransportIndexDeleteAction(Settings settings, ClusterService clusterService, TransportService transportService, ThreadPool threadPool, TransportShardDeleteAction deleteAction)

Method Summary

protected boolean	accumulateExceptions()
protected ClusterBlockException	checkGlobalBlock(ClusterState state, IndexDeleteRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, IndexDeleteRequest request)
protected IndexDeleteRequest	newRequestInstance()
protected IndexDeleteResponse	newResponseInstance(IndexDeleteRequest request, AtomicReferenceArray shardsResponses)
protected ShardDeleteRequest	newShardRequestInstance(IndexDeleteRequest request, int shardId)
protected GroupShardsIterator	shards(IndexDeleteRequest request)
protected String	transportAction()

Methods inherited from class org.elasticsearch.action.support.replication.TransportIndexReplicationOperationAction

doExecute

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

Constructor Detail

TransportIndexDeleteAction

@Inject
public TransportIndexDeleteAction(Settings settings,
                                         ClusterService clusterService,
                                         TransportService transportService,
                                         ThreadPool threadPool,
                                         TransportShardDeleteAction deleteAction)

Method Detail

newRequestInstance

protected IndexDeleteRequest newRequestInstance()

Specified by:

newRequestInstance in class TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

newResponseInstance

protected IndexDeleteResponse newResponseInstance(IndexDeleteRequest request,
                                                  AtomicReferenceArray shardsResponses)

Specified by:

newResponseInstance in class TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

transportAction

protected String transportAction()

Specified by:

transportAction in class TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 IndexDeleteRequest request)

Specified by:

checkGlobalBlock in class TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  IndexDeleteRequest request)

Specified by:

checkRequestBlock in class TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

shards

protected GroupShardsIterator shards(IndexDeleteRequest request)

Specified by:

shards in class TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

newShardRequestInstance

protected ShardDeleteRequest newShardRequestInstance(IndexDeleteRequest request,
                                                     int shardId)

Specified by:

newShardRequestInstance in class TransportIndexReplicationOperationAction<IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>