public class GlobalCheckpointSyncAction extends TransportReplicationAction<GlobalCheckpointSyncAction.Request,GlobalCheckpointSyncAction.Request,ReplicationResponse>
Modifier and Type | Class | Description |
---|---|---|
static class |
GlobalCheckpointSyncAction.Request |
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 |
ACTION_NAME |
deprecationLogger, logger, settings
actionName, indexNameExpressionResolver, taskManager, threadPool
clusterService, executor, indicesService, shardStateAction, transportOptions, transportPrimaryAction, transportReplicaAction, transportService
Constructor | Description |
---|---|
GlobalCheckpointSyncAction(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 void |
sendReplicaRequest(TransportReplicationAction.ConcreteReplicaRequest<GlobalCheckpointSyncAction.Request> replicaRequest,
DiscoveryNode node,
ActionListener<ReplicationOperation.ReplicaResponse> listener) |
Sends the specified replica request to the specified node.
|
protected TransportReplicationAction.PrimaryResult<GlobalCheckpointSyncAction.Request,ReplicationResponse> |
shardOperationOnPrimary(GlobalCheckpointSyncAction.Request request,
IndexShard indexShard) |
Primary operation on node with primary copy.
|
protected TransportReplicationAction.ReplicaResult |
shardOperationOnReplica(GlobalCheckpointSyncAction.Request request,
IndexShard indexShard) |
Synchronously execute the specified replica operation.
|
void |
updateGlobalCheckpointForShard(ShardId shardId) |
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, transportOptions
@Inject public GlobalCheckpointSyncAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)
public void updateGlobalCheckpointForShard(ShardId shardId)
protected ReplicationResponse newResponseInstance()
protected void sendReplicaRequest(TransportReplicationAction.ConcreteReplicaRequest<GlobalCheckpointSyncAction.Request> replicaRequest, DiscoveryNode node, ActionListener<ReplicationOperation.ReplicaResponse> listener)
TransportReplicationAction
sendReplicaRequest
in class TransportReplicationAction<GlobalCheckpointSyncAction.Request,GlobalCheckpointSyncAction.Request,ReplicationResponse>
replicaRequest
- the replica requestnode
- the node to send the request tolistener
- callback for handling the response or failureprotected TransportReplicationAction.PrimaryResult<GlobalCheckpointSyncAction.Request,ReplicationResponse> shardOperationOnPrimary(GlobalCheckpointSyncAction.Request request, IndexShard indexShard) throws java.lang.Exception
TransportReplicationAction
shardOperationOnPrimary
in class TransportReplicationAction<GlobalCheckpointSyncAction.Request,GlobalCheckpointSyncAction.Request,ReplicationResponse>
request
- the request to the primary shardindexShard
- the primary shard to perform the operation onjava.lang.Exception
protected TransportReplicationAction.ReplicaResult shardOperationOnReplica(GlobalCheckpointSyncAction.Request request, IndexShard indexShard) throws java.lang.Exception
TransportReplicationAction
IndexShard.acquireReplicaOperationPermit(long, long, ActionListener, String, Object)
.shardOperationOnReplica
in class TransportReplicationAction<GlobalCheckpointSyncAction.Request,GlobalCheckpointSyncAction.Request,ReplicationResponse>
request
- the request to the replica shardindexShard
- the replica shard to perform the operation onjava.lang.Exception