public class TransportIndexAction extends TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>
Allows for the following settings:
TransportShardReplicationOperationAction.InternalRequest, TransportShardReplicationOperationAction.PrimaryOperationRequest, 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, getIndexShardOperationsCounter, ignoreReplicaException, isConflictException, 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 Tuple<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–2016. All rights reserved.