public class TransportShardDeleteAction extends TransportShardReplicationOperationAction<ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>
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 |
---|
TransportShardDeleteAction(Settings settings,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
ThreadPool threadPool,
ShardStateAction shardStateAction,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkWriteConsistency() |
protected String |
executor() |
protected ShardDeleteRequest |
newReplicaRequestInstance() |
protected ShardDeleteRequest |
newRequestInstance() |
protected ShardDeleteResponse |
newResponseInstance() |
protected boolean |
resolveIndex() |
protected TransportShardReplicationOperationAction.PrimaryResponse<ShardDeleteResponse,ShardDeleteRequest> |
shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest) |
protected void |
shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest) |
protected ShardIterator |
shards(ClusterState clusterState,
TransportShardReplicationOperationAction.InternalRequest request) |
checkGlobalBlock, checkRequestBlock, doExecute, ignoreReplicaException, ignoreReplicas, isConflictException, postPrimaryOperation, resolveRequest, retryPrimaryException, transportOptions
execute, execute, forceThreadedListener
nodeName
@Inject public TransportShardDeleteAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters)
protected boolean checkWriteConsistency()
protected ShardDeleteRequest newRequestInstance()
protected ShardDeleteRequest newReplicaRequestInstance()
protected ShardDeleteResponse newResponseInstance()
protected String executor()
executor
in class TransportShardReplicationOperationAction<ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>
protected boolean resolveIndex()
resolveIndex
in class TransportShardReplicationOperationAction<ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>
protected TransportShardReplicationOperationAction.PrimaryResponse<ShardDeleteResponse,ShardDeleteRequest> shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
protected void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
protected ShardIterator shards(ClusterState clusterState, TransportShardReplicationOperationAction.InternalRequest request)
shards
in class TransportShardReplicationOperationAction<ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>
Copyright © 2009–2015. All rights reserved.