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, settingsactionName, indexNameExpressionResolver, taskManager, threadPoolclusterService, 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, nodeNameclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitexecute, execute, execute, executedoExecute, doExecute, getIndexShard, globalBlockLevel, indexBlockLevel, newReplicasProxy, registerRequestHandlers, resolveIndex, resolveRequest, retryPrimaryException, sendReplicaRequest, transportOptionspublic 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)
TransportReplicationActionshardOperationOnPrimary 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)
TransportReplicationActionIndexShard.acquireReplicaOperationPermit(long, long, ActionListener, String).shardOperationOnReplica in class TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>request - the request to the replica shardreplica - the replica shard to perform the operation on