public class RecoveryTarget extends AbstractComponent
Note, it can be safely assumed that there will only be a single recovery per shard (index+id) and not several of them (since we don't allocate several shard replicas to the same node).
Modifier and Type | Class and Description |
---|---|
static class |
RecoveryTarget.Actions |
static interface |
RecoveryTarget.RecoveryListener |
componentSettings, logger, settings
Constructor and Description |
---|
RecoveryTarget(Settings settings,
ThreadPool threadPool,
TransportService transportService,
IndicesLifecycle indicesLifecycle,
RecoverySettings recoverySettings,
ClusterService clusterService) |
Modifier and Type | Method and Description |
---|---|
RecoveryState |
recoveryState(IndexShard indexShard) |
protected void |
retryRecovery(RecoveryStatus recoveryStatus,
String reason,
TimeValue retryAfter,
StartRecoveryRequest currentRequest) |
void |
startRecovery(IndexShard indexShard,
RecoveryState.Type recoveryType,
DiscoveryNode sourceNode,
RecoveryTarget.RecoveryListener listener) |
nodeName
@Inject public RecoveryTarget(Settings settings, ThreadPool threadPool, TransportService transportService, IndicesLifecycle indicesLifecycle, RecoverySettings recoverySettings, ClusterService clusterService)
public RecoveryState recoveryState(IndexShard indexShard)
public void startRecovery(IndexShard indexShard, RecoveryState.Type recoveryType, DiscoveryNode sourceNode, RecoveryTarget.RecoveryListener listener)
protected void retryRecovery(RecoveryStatus recoveryStatus, String reason, TimeValue retryAfter, StartRecoveryRequest currentRequest)
Copyright © 2009–2015. All rights reserved.