org.apache.solr.cloud

Class RecoveryStrategy

java.lang.Object

java.lang.Thread

org.apache.solr.cloud.RecoveryStrategy

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class RecoveryStrategy
extends Thread
implements 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

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

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

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

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

Overrides:

run in class Thread

doRecovery

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

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

isClosed

public final boolean isClosed()