org.elasticsearch.indices.recovery
Class RecoveryTarget

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.indices.recovery.RecoveryTarget

public class RecoveryTarget
extends AbstractComponent

The recovery target handles recoveries of peer shards of the shard+node to recover to.

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).

Nested Class Summary

static class	RecoveryTarget.Actions
static interface	RecoveryTarget.RecoveryListener

Field Summary

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

RecoveryTarget(Settings settings, ThreadPool threadPool, TransportService transportService, IndicesService indicesService, IndicesLifecycle indicesLifecycle, RecoverySettings recoverySettings)

Method Summary

void	cancelRecovery(IndexShard indexShard)
RecoveryStatus	peerRecoveryStatus(ShardId shardId)
void	retryRecovery(StartRecoveryRequest request, RecoveryStatus status, RecoveryTarget.RecoveryListener listener)
void	startRecovery(StartRecoveryRequest request, InternalIndexShard indexShard, RecoveryTarget.RecoveryListener listener)

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RecoveryTarget

@Inject
public RecoveryTarget(Settings settings,
                             ThreadPool threadPool,
                             TransportService transportService,
                             IndicesService indicesService,
                             IndicesLifecycle indicesLifecycle,
                             RecoverySettings recoverySettings)

Method Detail

peerRecoveryStatus

public RecoveryStatus peerRecoveryStatus(ShardId shardId)

cancelRecovery

public void cancelRecovery(IndexShard indexShard)

startRecovery

public void startRecovery(StartRecoveryRequest request,
                          InternalIndexShard indexShard,
                          RecoveryTarget.RecoveryListener listener)

retryRecovery

public void retryRecovery(StartRecoveryRequest request,
                          RecoveryStatus status,
                          RecoveryTarget.RecoveryListener listener)