org.apache.solr.cloud

Class MiniSolrCloudCluster

java.lang.Object

org.apache.solr.cloud.MiniSolrCloudCluster

public class MiniSolrCloudCluster
extends Object

"Mini" SolrCloud cluster to be used for testing

Constructor Summary

Constructors

Constructor and Description
MiniSolrCloudCluster(int numServers, File baseDir, File solrXml, JettyConfig jettyConfig) Create a MiniSolrCloudCluster
MiniSolrCloudCluster(int numServers, String hostContext, File baseDir, File solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters) Create a MiniSolrCloudCluster
MiniSolrCloudCluster(int numServers, String hostContext, File baseDir, File solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters, SSLConfig sslConfig) Create a MiniSolrCloudCluster

Method Summary

Modifier and Type	Method and Description
protected CloudSolrClient	buildSolrClient()
NamedList<Object>	createCollection(String name, int numShards, int replicationFactor, String configName, Map<String,String> collectionProperties)
NamedList<Object>	createCollection(String name, int numShards, int replicationFactor, String configName, String createNodeSet, String asyncId, Map<String,String> collectionProperties)
NamedList<Object>	deleteCollection(String name)
List<JettySolrRunner>	getJettySolrRunners()
CloudSolrClient	getSolrClient()
ZkTestServer	getZkServer()
void	shutdown() Shut down the cluster, including all Solr nodes and ZooKeeper
JettySolrRunner	startJettySolrRunner() Start a new Solr instance, using the default config
JettySolrRunner	startJettySolrRunner(JettyConfig config) Start a new Solr instance
JettySolrRunner	startJettySolrRunner(String hostContext, JettyConfig config) Start a new Solr instance on a particular servlet context
JettySolrRunner	startJettySolrRunner(String hostContext, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters) Start a new Solr instance
JettySolrRunner	startJettySolrRunner(String hostContext, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters, SSLConfig sslConfig) Start a new Solr instance
JettySolrRunner	stopJettySolrRunner(int index) Stop a Solr instance
protected JettySolrRunner	stopJettySolrRunner(JettySolrRunner jetty)
void	uploadConfigDir(File configDir, String configName)

Methods inherited from class java.lang.Object

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

Constructor Detail

MiniSolrCloudCluster

public MiniSolrCloudCluster(int numServers,
                            String hostContext,
                            File baseDir,
                            File solrXml,
                            SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
                            SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters)
                     throws Exception

Create a MiniSolrCloudCluster

Parameters:

numServers - number of Solr servers to start

hostContext - context path of Solr servers used by Jetty

baseDir - base directory that the mini cluster should be run from

solrXml - solr.xml file to be uploaded to ZooKeeper

extraServlets - Extra servlets to be started by Jetty

extraRequestFilters - extra filters to be started by Jetty

Throws:

Exception - if there was an error starting the cluster

MiniSolrCloudCluster

public MiniSolrCloudCluster(int numServers,
                            String hostContext,
                            File baseDir,
                            File solrXml,
                            SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
                            SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters,
                            SSLConfig sslConfig)
                     throws Exception

Create a MiniSolrCloudCluster

Parameters:

numServers - number of Solr servers to start

hostContext - context path of Solr servers used by Jetty

baseDir - base directory that the mini cluster should be run from

solrXml - solr.xml file to be uploaded to ZooKeeper

extraServlets - Extra servlets to be started by Jetty

extraRequestFilters - extra filters to be started by Jetty

sslConfig - SSL configuration

Throws:

Exception - if there was an error starting the cluster

MiniSolrCloudCluster

public MiniSolrCloudCluster(int numServers,
                            File baseDir,
                            File solrXml,
                            JettyConfig jettyConfig)
                     throws Exception

Create a MiniSolrCloudCluster

Parameters:

numServers - number of Solr servers to start

baseDir - base directory that the mini cluster should be run from

solrXml - solr.xml file to be uploaded to ZooKeeper

jettyConfig - Jetty configuration

Throws:

Exception - if there was an error starting the cluster

Method Detail

getZkServer

public ZkTestServer getZkServer()

Returns:

ZooKeeper server used by the MiniCluster

getJettySolrRunners

public List<JettySolrRunner> getJettySolrRunners()

Returns:

Unmodifiable list of all the currently started Solr Jettys.

startJettySolrRunner

public JettySolrRunner startJettySolrRunner(String hostContext,
                                            SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
                                            SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters)
                                     throws Exception

Start a new Solr instance

Parameters:

hostContext - context path of Solr servers used by Jetty

extraServlets - Extra servlets to be started by Jetty

extraRequestFilters - extra filters to be started by Jetty

Returns:

new Solr instance

Throws:

Exception

startJettySolrRunner

public JettySolrRunner startJettySolrRunner(String hostContext,
                                            SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
                                            SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters,
                                            SSLConfig sslConfig)
                                     throws Exception

Start a new Solr instance

Parameters:

hostContext - context path of Solr servers used by Jetty

extraServlets - Extra servlets to be started by Jetty

extraRequestFilters - extra filters to be started by Jetty

sslConfig - SSL configuration

Returns:

new Solr instance

Throws:

Exception

startJettySolrRunner

public JettySolrRunner startJettySolrRunner(JettyConfig config)
                                     throws Exception

Start a new Solr instance

Parameters:

config - a JettyConfig for the instance's JettySolrRunner

Returns:

a JettySolrRunner

Throws:

Exception

startJettySolrRunner

public JettySolrRunner startJettySolrRunner(String hostContext,
                                            JettyConfig config)
                                     throws Exception

Start a new Solr instance on a particular servlet context

Parameters:

hostContext - the context to run on

config - a JettyConfig for the instance's JettySolrRunner

Returns:

a JettySolrRunner

Throws:

Exception

startJettySolrRunner

public JettySolrRunner startJettySolrRunner()
                                     throws Exception

Start a new Solr instance, using the default config

Returns:

a JettySolrRunner

Throws:

Exception

stopJettySolrRunner

public JettySolrRunner stopJettySolrRunner(int index)
                                    throws Exception

Stop a Solr instance

Parameters:

index - the index of node in collection returned by getJettySolrRunners()

Returns:

the shut down node

Throws:

Exception

stopJettySolrRunner

protected JettySolrRunner stopJettySolrRunner(JettySolrRunner jetty)
                                       throws Exception

Throws:

Exception

uploadConfigDir

public void uploadConfigDir(File configDir,
                            String configName)
                     throws IOException,
                            org.apache.zookeeper.KeeperException,
                            InterruptedException

Throws:

IOException

org.apache.zookeeper.KeeperException

InterruptedException

createCollection

public NamedList<Object> createCollection(String name,
                                          int numShards,
                                          int replicationFactor,
                                          String configName,
                                          Map<String,String> collectionProperties)
                                   throws SolrServerException,
                                          IOException

Throws:

SolrServerException

IOException

createCollection

public NamedList<Object> createCollection(String name,
                                          int numShards,
                                          int replicationFactor,
                                          String configName,
                                          String createNodeSet,
                                          String asyncId,
                                          Map<String,String> collectionProperties)
                                   throws SolrServerException,
                                          IOException

Throws:

SolrServerException

IOException

deleteCollection

public NamedList<Object> deleteCollection(String name)
                                   throws SolrServerException,
                                          IOException

Throws:

SolrServerException

IOException

shutdown

public void shutdown()
              throws Exception

Shut down the cluster, including all Solr nodes and ZooKeeper

Throws:

Exception

getSolrClient

public CloudSolrClient getSolrClient()

buildSolrClient

protected CloudSolrClient buildSolrClient()