org.apache.solr.cloud

Class RecoveryStrategy

java.lang.Object

org.apache.solr.cloud.RecoveryStrategy

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class RecoveryStrategy
extends Object
implements Runnable, Closeable

This class may change in future and customisations are not supported between versions in terms of API or back compat behaviour.

WARNING: This API is experimental and might change in incompatible ways in the next release.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RecoveryStrategy.Builder
static interface	RecoveryStrategy.RecoveryListener

Field Summary

Fields

Modifier and Type	Field and Description
static Runnable	testing_beforeReplayBufferingUpdates

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RecoveryStrategy(CoreContainer cc, CoreDescriptor cd, RecoveryStrategy.RecoveryListener recoveryListener)

Method Summary

Modifier and Type	Method and Description
void	close()
void	doRecovery(SolrCore core)
void	doSyncOrReplicateRecovery(SolrCore core)
int	getMaxRetries()
boolean	getRecoveringAfterStartup()
protected String	getReplicateLeaderUrl(ZkNodeProps leaderprops) This method may change in future and customisations are not supported between versions in terms of API or back compat behaviour.
int	getStartingRecoveryDelayMilliSeconds()
int	getWaitForUpdatesWithStaleStatePauseMilliSeconds()
boolean	isClosed()
void	run()
void	setMaxRetries(int maxRetries)
void	setRecoveringAfterStartup(boolean recoveringAfterStartup)
void	setStartingRecoveryDelayMilliSeconds(int startingRecoveryDelayMilliSeconds)
void	setWaitForUpdatesWithStaleStatePauseMilliSeconds(int waitForUpdatesWithStaleStatePauseMilliSeconds)

Methods inherited from class java.lang.Object

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

Field Detail

testing_beforeReplayBufferingUpdates

public static Runnable testing_beforeReplayBufferingUpdates

Constructor Detail

RecoveryStrategy

protected RecoveryStrategy(CoreContainer cc,
                           CoreDescriptor cd,
                           RecoveryStrategy.RecoveryListener recoveryListener)

Method Detail

getWaitForUpdatesWithStaleStatePauseMilliSeconds

public final int getWaitForUpdatesWithStaleStatePauseMilliSeconds()

setWaitForUpdatesWithStaleStatePauseMilliSeconds

public final void setWaitForUpdatesWithStaleStatePauseMilliSeconds(int waitForUpdatesWithStaleStatePauseMilliSeconds)

getMaxRetries

public final int getMaxRetries()

setMaxRetries

public final void setMaxRetries(int maxRetries)

getStartingRecoveryDelayMilliSeconds

public final int getStartingRecoveryDelayMilliSeconds()

setStartingRecoveryDelayMilliSeconds

public final void setStartingRecoveryDelayMilliSeconds(int startingRecoveryDelayMilliSeconds)

getRecoveringAfterStartup

public final boolean getRecoveringAfterStartup()

setRecoveringAfterStartup

public final void setRecoveringAfterStartup(boolean recoveringAfterStartup)

close

public final void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getReplicateLeaderUrl

protected String getReplicateLeaderUrl(ZkNodeProps leaderprops)

This method may change in future and customisations are not supported between versions in terms of API or back compat behaviour.

WARNING: This API is experimental and might change in incompatible ways in the next release.

run

public final void run()

Specified by:

run in interface Runnable

doRecovery

public final void doRecovery(SolrCore core)
                      throws org.apache.zookeeper.KeeperException,
                             InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

doSyncOrReplicateRecovery

public final void doSyncOrReplicateRecovery(SolrCore core)
                                     throws org.apache.zookeeper.KeeperException,
                                            InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

isClosed

public final boolean isClosed()