Package 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	Description
static class	RecoveryStrategy.Builder
static interface	RecoveryStrategy.RecoveryListener

Field Summary

Fields

Modifier and Type	Field	Description
static Runnable	testing_beforeReplayBufferingUpdates

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

testing_beforeReplayBufferingUpdates

public static Runnable testing_beforeReplayBufferingUpdates

Constructor Details

RecoveryStrategy

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

Method Details

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 AutoCloseable

Specified by:

close in interface Closeable

getReplicateLeaderUrl

protected String getReplicateLeaderUrl(org.apache.solr.common.cloud.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 Exception

Throws:

Exception

doSyncOrReplicateRecovery

public final void doSyncOrReplicateRecovery(SolrCore core)
                                     throws Exception

Throws:

Exception

isClosed

public final boolean isClosed()