public class TransportShardRefreshAction extends TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>
TransportReplicationAction.ConcreteReplicaRequest<R extends TransportRequest>, TransportReplicationAction.ConcreteShardRequest<R extends TransportRequest>, TransportReplicationAction.OperationTransportHandler, TransportReplicationAction.PrimaryOperationTransportHandler, TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>, TransportReplicationAction.ReplicaOperationTransportHandler, TransportReplicationAction.ReplicaResponse, TransportReplicationAction.ReplicaResult, TransportReplicationAction.ReplicasProxy, TransportReplicationAction.RetryOnReplicaException
Modifier and Type | Field | Description |
---|---|---|
static java.lang.String |
NAME |
deprecationLogger, logger, settings
actionName, indexNameExpressionResolver, taskManager, threadPool
clusterService, executor, indicesService, shardStateAction, transportOptions, transportPrimaryAction, transportReplicaAction, transportService
Constructor | Description |
---|---|
TransportShardRefreshAction(Settings settings,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
ThreadPool threadPool,
ShardStateAction shardStateAction,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver) |
Modifier and Type | Method | Description |
---|---|---|
protected ReplicationResponse |
newResponseInstance() |
|
protected TransportReplicationAction.PrimaryResult |
shardOperationOnPrimary(BasicReplicationRequest shardRequest,
IndexShard primary) |
Primary operation on node with primary copy.
|
protected TransportReplicationAction.ReplicaResult |
shardOperationOnReplica(BasicReplicationRequest request,
IndexShard replica) |
Synchronously execute the specified replica operation.
|
logDeprecatedSetting, logRemovedSetting, nodeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execute, execute, execute, execute
doExecute, doExecute, getIndexShard, globalBlockLevel, indexBlockLevel, newReplicasProxy, registerRequestHandlers, resolveIndex, resolveRequest, retryPrimaryException, sendReplicaRequest, transportOptions
public static final java.lang.String NAME
@Inject public TransportShardRefreshAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)
protected ReplicationResponse newResponseInstance()
newResponseInstance
in class TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>
protected TransportReplicationAction.PrimaryResult shardOperationOnPrimary(BasicReplicationRequest shardRequest, IndexShard primary)
TransportReplicationAction
shardOperationOnPrimary
in class TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>
shardRequest
- the request to the primary shardprimary
- the primary shard to perform the operation onprotected TransportReplicationAction.ReplicaResult shardOperationOnReplica(BasicReplicationRequest request, IndexShard replica)
TransportReplicationAction
IndexShard.acquireReplicaOperationPermit(long, long, ActionListener, String, Object)
.shardOperationOnReplica
in class TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>
request
- the request to the replica shardreplica
- the replica shard to perform the operation on