public class TransportIndexAction extends TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
Allows for the following settings:
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 |
---|
TransportIndexAction(Settings settings,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
ThreadPool threadPool,
ShardStateAction shardStateAction,
TransportCreateIndexAction createIndexAction,
MappingUpdatedAction mappingUpdatedAction,
ActionFilters actionFilters) |
checkGlobalBlock, checkRequestBlock, ignoreReplicaException, ignoreReplicas, isConflictException, postPrimaryOperation, retryPrimaryException, transportOptions
execute, execute, forceThreadedListener
nodeName
@Inject public TransportIndexAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, TransportCreateIndexAction createIndexAction, MappingUpdatedAction mappingUpdatedAction, ActionFilters actionFilters)
protected void doExecute(IndexRequest request, ActionListener<IndexResponse> listener)
doExecute
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
protected boolean resolveIndex()
resolveIndex
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
protected boolean resolveRequest(ClusterState state, TransportShardReplicationOperationAction.InternalRequest request, ActionListener<IndexResponse> indexResponseActionListener)
TransportShardReplicationOperationAction
resolveRequest
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
protected boolean checkWriteConsistency()
checkWriteConsistency
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
protected IndexRequest newRequestInstance()
newRequestInstance
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
protected IndexRequest newReplicaRequestInstance()
newReplicaRequestInstance
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
protected IndexResponse newResponseInstance()
newResponseInstance
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
protected String executor()
executor
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
protected ShardIterator shards(ClusterState clusterState, TransportShardReplicationOperationAction.InternalRequest request)
shards
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
protected TransportShardReplicationOperationAction.PrimaryResponse<IndexResponse,IndexRequest> shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest) throws Throwable
shardOperationOnPrimary
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
Throwable
protected void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
shardOperationOnReplica
in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
Copyright © 2009–2015. All rights reserved.