de.hybris.platform.solrserver.impl

Class AbstractSolrServerController

java.lang.Object

de.hybris.platform.solrserver.impl.AbstractSolrServerController

All Implemented Interfaces:

SolrServerController

Direct Known Subclasses:

AbstractSolrServerControllerTest.AbstractSolrServerControllerSpy, UnixSolrServerController, WindowsSolrServerController

public abstract class AbstractSolrServerController
extends java.lang.Object
implements SolrServerController

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	AbstractSolrServerController.CommandBuilder
protected static interface	AbstractSolrServerController.CommandParamsBuilder
protected static class	AbstractSolrServerController.CommandResult
protected static class	AbstractSolrServerController.ServerStatus
protected static interface	AbstractSolrServerController.ServerStatusFunction
protected static class	AbstractSolrServerController.ServerStatusOutput

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BASIC_AUTH_TYPE
static java.lang.String	CONFIGSETS_PATH
static java.lang.String	CORES_PATH
static java.lang.String	FORCE_RESTART
static boolean	FORCE_RESTART_DEFAULT_VALUE
static java.lang.String	JSON_REGEX
static java.lang.String	MAX_STATUS_RETRIES
static int	MAX_STATUS_RETRIES_DEFAULT_VALUE
static java.lang.String	RUNNING_CHECK_REGEX
static java.lang.String	SOLR_START_COMMAND
static java.lang.String	SOLR_STATUS_COMMAND
static java.lang.String	SOLR_STOP_COMMAND
static java.lang.String	SOLR_ZK_CP_COMMAND
static java.lang.String	SOLR_ZK_UPCONFIG_COMMAND
static java.lang.String	STATUS_INTERVAL
static long	STATUS_INTERVAL_DEFAULT_VALUE
static java.lang.String	TIMEOUT
static long	TIMEOUT_DEFAULT_VALUE
static java.lang.String	ZK_CLUSTERPROP_COMMAND
static java.lang.String	ZK_DATA_PATH

Constructor Summary

Constructors

Constructor and Description
AbstractSolrServerController()

Method Summary

Modifier and Type	Method and Description
protected void	addCommand(java.util.List<java.lang.String> commandParams, java.lang.String command)
protected void	buildCommonSolrCommandParams(SolrInstance solrInstance, java.lang.ProcessBuilder processBuilder)
protected AbstractSolrServerController.CommandResult	callCommand(SolrInstance solrInstance, java.lang.String command, AbstractSolrServerController.CommandBuilder commandBuilder, AbstractSolrServerController.CommandParamsBuilder commandParamsBuilder)
protected AbstractSolrServerController.CommandResult	callSolrCommand(SolrInstance solrInstance, java.lang.String command, AbstractSolrServerController.CommandParamsBuilder commandParamsBuilder)
protected AbstractSolrServerController.CommandResult	callZKCommand(SolrInstance solrInstance, java.lang.String command, AbstractSolrServerController.CommandParamsBuilder commandParamsBuilder)
protected java.util.Map<java.lang.Integer,AbstractSolrServerController.ServerStatusOutput>	collectServerStatusOutput(java.lang.String commandOutput)
protected abstract void	configureSolrCommandInvocation(SolrInstance solrInstance, java.lang.ProcessBuilder processBuilder, java.lang.String command)
protected abstract void	configureZKCommandInvocation(SolrInstance solrInstance, java.lang.ProcessBuilder processBuilder, java.lang.String command)
protected void	ensureToStartSolr(SolrInstance solrInstance)
protected void	ensureToStopSolr(SolrInstance solrInstance)
protected int	getMaxStatusRetries()
protected AbstractSolrServerController.ServerStatus	getSolrServerStatus(SolrInstance solrInstance)
protected long	getStatusInterval()
protected long	getTimeout()
protected boolean	isCorrespondingServerForInstance(SolrInstance solrInstance, AbstractSolrServerController.ServerStatus serverStatus)
protected boolean	isForceRestart()
protected java.lang.String	resolveZkHost(SolrInstance solrInstance)
protected AbstractSolrServerController.ServerStatus	retryGetStatusUntilConditionIsTrue(SolrInstance solrInstance, AbstractSolrServerController.ServerStatusFunction condition, java.lang.String retryMessage, java.lang.String errorMessage)
protected void	setSolrCloudConfigProperties(SolrInstance solrInstance, java.lang.String zkHost)
void	start(SolrInstance solrInstance) Starts the Solr server for a given instance.
void	stop(SolrInstance solrInstance) Stops the Solr server for a given instance.
protected void	uploadSolrCloudConfigFiles(SolrInstance solrInstance, java.lang.String zkHost)
protected void	uploadSolrCloudConfigSets(SolrInstance solrInstance, java.lang.String zkHost)
protected void	uploadSolrConfig(SolrInstance solrInstance)

Methods inherited from class java.lang.Object

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

Field Detail

RUNNING_CHECK_REGEX

public static final java.lang.String RUNNING_CHECK_REGEX

See Also:

Constant Field Values

JSON_REGEX

public static final java.lang.String JSON_REGEX

See Also:

Constant Field Values

SOLR_STATUS_COMMAND

public static final java.lang.String SOLR_STATUS_COMMAND

See Also:

Constant Field Values

SOLR_START_COMMAND

public static final java.lang.String SOLR_START_COMMAND

See Also:

Constant Field Values

SOLR_STOP_COMMAND

public static final java.lang.String SOLR_STOP_COMMAND

See Also:

Constant Field Values

SOLR_ZK_CP_COMMAND

public static final java.lang.String SOLR_ZK_CP_COMMAND

See Also:

Constant Field Values

SOLR_ZK_UPCONFIG_COMMAND

public static final java.lang.String SOLR_ZK_UPCONFIG_COMMAND

See Also:

Constant Field Values

ZK_CLUSTERPROP_COMMAND

public static final java.lang.String ZK_CLUSTERPROP_COMMAND

See Also:

Constant Field Values

FORCE_RESTART

public static final java.lang.String FORCE_RESTART

See Also:

Constant Field Values

FORCE_RESTART_DEFAULT_VALUE

public static final boolean FORCE_RESTART_DEFAULT_VALUE

See Also:

Constant Field Values

TIMEOUT

public static final java.lang.String TIMEOUT

See Also:

Constant Field Values

TIMEOUT_DEFAULT_VALUE

public static final long TIMEOUT_DEFAULT_VALUE

See Also:

Constant Field Values

MAX_STATUS_RETRIES

public static final java.lang.String MAX_STATUS_RETRIES

See Also:

Constant Field Values

MAX_STATUS_RETRIES_DEFAULT_VALUE

public static final int MAX_STATUS_RETRIES_DEFAULT_VALUE

See Also:

Constant Field Values

STATUS_INTERVAL

public static final java.lang.String STATUS_INTERVAL

See Also:

Constant Field Values

STATUS_INTERVAL_DEFAULT_VALUE

public static final long STATUS_INTERVAL_DEFAULT_VALUE

See Also:

Constant Field Values

CONFIGSETS_PATH

public static final java.lang.String CONFIGSETS_PATH

See Also:

Constant Field Values

CORES_PATH

public static final java.lang.String CORES_PATH

See Also:

Constant Field Values

ZK_DATA_PATH

public static final java.lang.String ZK_DATA_PATH

See Also:

Constant Field Values

BASIC_AUTH_TYPE

public static final java.lang.String BASIC_AUTH_TYPE

See Also:

Constant Field Values

Constructor Detail

AbstractSolrServerController

public AbstractSolrServerController()

Method Detail

start

public void start(SolrInstance solrInstance)
           throws SolrServerException

Description copied from interface: SolrServerController

Starts the Solr server for a given instance.

Specified by:

start in interface SolrServerController

Parameters:

solrInstance - - the Solr instance

Throws:

SolrServerException - - if an error occurs while starting the Solr server

ensureToStartSolr

protected void ensureToStartSolr(SolrInstance solrInstance)
                          throws SolrServerException,
                                 java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

uploadSolrConfig

protected void uploadSolrConfig(SolrInstance solrInstance)
                         throws SolrServerException,
                                java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

uploadSolrCloudConfigFiles

protected void uploadSolrCloudConfigFiles(SolrInstance solrInstance,
                                          java.lang.String zkHost)
                                   throws SolrServerException,
                                          java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

uploadSolrCloudConfigSets

protected void uploadSolrCloudConfigSets(SolrInstance solrInstance,
                                         java.lang.String zkHost)
                                  throws SolrServerException,
                                         java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

setSolrCloudConfigProperties

protected void setSolrCloudConfigProperties(SolrInstance solrInstance,
                                            java.lang.String zkHost)
                                     throws SolrServerException,
                                            java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

stop

public void stop(SolrInstance solrInstance)
          throws SolrServerException

Description copied from interface: SolrServerController

Stops the Solr server for a given instance.

Specified by:

stop in interface SolrServerController

Parameters:

solrInstance - - the Solr instance

Throws:

SolrServerException - - if an error occurs while stopping the Solr server

ensureToStopSolr

protected void ensureToStopSolr(SolrInstance solrInstance)
                         throws SolrServerException,
                                java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

callSolrCommand

protected AbstractSolrServerController.CommandResult callSolrCommand(SolrInstance solrInstance,
                                                                     java.lang.String command,
                                                                     AbstractSolrServerController.CommandParamsBuilder commandParamsBuilder)
                                                              throws SolrServerException,
                                                                     java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

callZKCommand

protected AbstractSolrServerController.CommandResult callZKCommand(SolrInstance solrInstance,
                                                                   java.lang.String command,
                                                                   AbstractSolrServerController.CommandParamsBuilder commandParamsBuilder)
                                                            throws SolrServerException,
                                                                   java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

callCommand

protected AbstractSolrServerController.CommandResult callCommand(SolrInstance solrInstance,
                                                                 java.lang.String command,
                                                                 AbstractSolrServerController.CommandBuilder commandBuilder,
                                                                 AbstractSolrServerController.CommandParamsBuilder commandParamsBuilder)
                                                          throws SolrServerException,
                                                                 java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

addCommand

protected void addCommand(java.util.List<java.lang.String> commandParams,
                          java.lang.String command)

configureSolrCommandInvocation

protected abstract void configureSolrCommandInvocation(SolrInstance solrInstance,
                                                       java.lang.ProcessBuilder processBuilder,
                                                       java.lang.String command)

configureZKCommandInvocation

protected abstract void configureZKCommandInvocation(SolrInstance solrInstance,
                                                     java.lang.ProcessBuilder processBuilder,
                                                     java.lang.String command)

buildCommonSolrCommandParams

protected void buildCommonSolrCommandParams(SolrInstance solrInstance,
                                            java.lang.ProcessBuilder processBuilder)

resolveZkHost

protected java.lang.String resolveZkHost(SolrInstance solrInstance)

getSolrServerStatus

protected AbstractSolrServerController.ServerStatus getSolrServerStatus(SolrInstance solrInstance)
                                                                 throws SolrServerException,
                                                                        java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

collectServerStatusOutput

protected java.util.Map<java.lang.Integer,AbstractSolrServerController.ServerStatusOutput> collectServerStatusOutput(java.lang.String commandOutput)

retryGetStatusUntilConditionIsTrue

protected AbstractSolrServerController.ServerStatus retryGetStatusUntilConditionIsTrue(SolrInstance solrInstance,
                                                                                       AbstractSolrServerController.ServerStatusFunction condition,
                                                                                       java.lang.String retryMessage,
                                                                                       java.lang.String errorMessage)
                                                                                throws SolrServerException,
                                                                                       java.lang.InterruptedException

Throws:

SolrServerException

java.lang.InterruptedException

isCorrespondingServerForInstance

protected boolean isCorrespondingServerForInstance(SolrInstance solrInstance,
                                                   AbstractSolrServerController.ServerStatus serverStatus)
                                            throws SolrServerException

Throws:

SolrServerException

isForceRestart

protected boolean isForceRestart()

getMaxStatusRetries

protected int getMaxStatusRetries()

getTimeout

protected long getTimeout()

getStatusInterval

protected long getStatusInterval()