public class TransportDeleteAction extends TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
TransportShardReplicationOperationAction.AsyncShardOperationAction, TransportShardReplicationOperationAction.InternalRequest, TransportShardReplicationOperationAction.PrimaryOperationRequest, TransportShardReplicationOperationAction.PrimaryResponse<Response,ReplicaRequest>, TransportShardReplicationOperationAction.ReplicaOperationRequest
clusterService, defaultReplicationType, defaultWriteConsistencyLevel, indicesService, shardStateAction, transportOptions, transportService
actionName, threadPool
componentSettings, logger, settings
Constructor and Description |
---|
TransportDeleteAction(Settings settings,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
ThreadPool threadPool,
ShardStateAction shardStateAction,
TransportCreateIndexAction createIndexAction,
TransportIndexDeleteAction indexDeleteAction,
ActionFilters actionFilters) |
checkGlobalBlock, checkRequestBlock, ignoreReplicaException, ignoreReplicas, isConflictException, postPrimaryOperation, retryPrimaryException, transportOptions
execute, execute, forceThreadedListener
nodeName
@Inject public TransportDeleteAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, TransportCreateIndexAction createIndexAction, TransportIndexDeleteAction indexDeleteAction, ActionFilters actionFilters)
protected String executor()
executor
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected void doExecute(DeleteRequest request, ActionListener<DeleteResponse> listener)
doExecute
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected boolean resolveIndex()
resolveIndex
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected boolean resolveRequest(ClusterState state, TransportShardReplicationOperationAction.InternalRequest request, ActionListener<DeleteResponse> listener)
TransportShardReplicationOperationAction
resolveRequest
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected boolean checkWriteConsistency()
checkWriteConsistency
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected DeleteRequest newRequestInstance()
newRequestInstance
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected DeleteRequest newReplicaRequestInstance()
newReplicaRequestInstance
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected DeleteResponse newResponseInstance()
newResponseInstance
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected TransportShardReplicationOperationAction.PrimaryResponse<DeleteResponse,DeleteRequest> shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
shardOperationOnPrimary
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
shardOperationOnReplica
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
protected ShardIterator shards(ClusterState clusterState, TransportShardReplicationOperationAction.InternalRequest request)
shards
in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
Copyright © 2009–2015. All rights reserved.