org.apache.solr.cloud

Class MiniSolrCloudCluster

java.lang.Object

org.apache.solr.cloud.MiniSolrCloudCluster

Direct Known Subclasses:

HttpParamDelegationTokenMiniSolrCloudCluster

public class MiniSolrCloudCluster
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_CLOUD_SOLR_XML

Constructor Summary

Constructors

Constructor and Description
MiniSolrCloudCluster(int numServers, Path baseDir, String solrXml, org.apache.solr.client.solrj.embedded.JettyConfig jettyConfig) Create a MiniSolrCloudCluster
MiniSolrCloudCluster(int numServers, Path baseDir, String solrXml, org.apache.solr.client.solrj.embedded.JettyConfig jettyConfig, ZkTestServer zkTestServer)
MiniSolrCloudCluster(int numServers, String hostContext, File solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class,String> extraRequestFilters) "Mini" SolrCloud cluster to be used for testing
MiniSolrCloudCluster(int numServers, String hostContext, Path baseDir, File solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class,String> extraRequestFilters) "Mini" SolrCloud cluster to be used for testing
MiniSolrCloudCluster(int numServers, String hostContext, Path baseDir, File solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class,String> extraRequestFilters, org.apache.solr.client.solrj.embedded.SSLConfig sslConfig) "Mini" SolrCloud cluster to be used for testing
MiniSolrCloudCluster(int numServers, String hostContext, Path baseDir, File solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class,String> extraRequestFilters, org.apache.solr.client.solrj.embedded.SSLConfig sslConfig, ZkTestServer zkTestServer) "Mini" SolrCloud cluster to be used for testing
MiniSolrCloudCluster(int numServers, String hostContext, Path baseDir, String solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class,String> extraRequestFilters, org.apache.solr.client.solrj.embedded.SSLConfig sslConfig, ZkTestServer zkTestServer) "Mini" SolrCloud cluster to be used for testing

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.solr.common.util.NamedList<Object>	createCollection(String name, int numShards, int replicationFactor, String configName, Map<String,String> collectionProperties)
org.apache.solr.common.util.NamedList<Object>	createCollection(String name, int numShards, int replicationFactor, String configName, String createNodeSet, Map<String,String> collectionProperties)
org.apache.solr.common.util.NamedList<Object>	deleteCollection(String name)
List<org.apache.solr.client.solrj.embedded.JettySolrRunner>	getJettySolrRunners()
org.apache.solr.client.solrj.embedded.JettySolrRunner	getRandomJetty(Random random)
org.apache.solr.client.solrj.embedded.JettySolrRunner	getReplicaJetty(org.apache.solr.common.cloud.Replica replica) Return the jetty that a particular replica resides on
org.apache.solr.client.solrj.impl.CloudSolrServer	getSolrClient()
ZkTestServer	getZkServer()
void	init(int numServers, String hostContext, byte[] solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class,String> extraRequestFilters, org.apache.solr.client.solrj.embedded.SSLConfig sslConfig, ZkTestServer zkTestServer)
String	newNodeName()
void	shutdown() Shut down the cluster, including all Solr nodes and ZooKeeper
org.apache.solr.client.solrj.embedded.JettySolrRunner	startJettySolrRunner(String name, String hostContext, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class,String> extraRequestFilters) Start a new Solr instance
org.apache.solr.client.solrj.embedded.JettySolrRunner	startJettySolrRunner(String name, String hostContext, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class,String> extraRequestFilters, org.apache.solr.client.solrj.embedded.SSLConfig sslConfig) Start a new Solr instance
org.apache.solr.client.solrj.embedded.JettySolrRunner	stopJettySolrRunner(int index) Stop a Solr instance
void	uploadConfigDir(File configDir, String configName)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CLOUD_SOLR_XML

public static final String DEFAULT_CLOUD_SOLR_XML

See Also:

Constant Field Values

Constructor Detail

MiniSolrCloudCluster

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

"Mini" SolrCloud cluster to be used for testing

Parameters:

numServers - number of Solr servers to start

hostContext - context path of Solr servers used by Jetty

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

MiniSolrCloudCluster

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

"Mini" SolrCloud cluster to be used for testing

Parameters:

numServers - number of Solr servers to start

hostContext - context path of Solr servers used by Jetty

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

MiniSolrCloudCluster

public MiniSolrCloudCluster(int numServers,
                    String hostContext,
                    Path baseDir,
                    File solrXml,
                    SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
                    SortedMap<Class,String> extraRequestFilters,
                    org.apache.solr.client.solrj.embedded.SSLConfig sslConfig)
                     throws Exception

"Mini" SolrCloud cluster to be used for testing

Parameters:

numServers - number of Solr servers to start

hostContext - context path of Solr servers used by Jetty

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

MiniSolrCloudCluster

public MiniSolrCloudCluster(int numServers,
                    String hostContext,
                    Path baseDir,
                    File solrXml,
                    SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
                    SortedMap<Class,String> extraRequestFilters,
                    org.apache.solr.client.solrj.embedded.SSLConfig sslConfig,
                    ZkTestServer zkTestServer)
                     throws Exception

"Mini" SolrCloud cluster to be used for testing

Parameters:

numServers - number of Solr servers to start

hostContext - context path of Solr servers used by Jetty

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

zkTestServer - ZkTestServer to use. If null, one will be created

Throws:

Exception

MiniSolrCloudCluster

public MiniSolrCloudCluster(int numServers,
                    Path baseDir,
                    String solrXml,
                    org.apache.solr.client.solrj.embedded.JettyConfig jettyConfig)
                     throws Exception

Create a MiniSolrCloudCluster

Parameters:

numServers - number of Solr servers to start

solrXml - solr.xml file to be uploaded to ZooKeeper

jettyConfig - Jetty configuration

Throws:

Exception - if there was an error starting the cluster

MiniSolrCloudCluster

public MiniSolrCloudCluster(int numServers,
                    Path baseDir,
                    String solrXml,
                    org.apache.solr.client.solrj.embedded.JettyConfig jettyConfig,
                    ZkTestServer zkTestServer)
                     throws Exception

Throws:

Exception

MiniSolrCloudCluster

public MiniSolrCloudCluster(int numServers,
                    String hostContext,
                    Path baseDir,
                    String solrXml,
                    SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
                    SortedMap<Class,String> extraRequestFilters,
                    org.apache.solr.client.solrj.embedded.SSLConfig sslConfig,
                    ZkTestServer zkTestServer)
                     throws Exception

"Mini" SolrCloud cluster to be used for testing

Parameters:

numServers - number of Solr servers to start

hostContext - context path of Solr servers used by Jetty

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

zkTestServer - ZkTestServer to use. If null, one will be created

Throws:

Exception

Method Detail

init

public void init(int numServers,
        String hostContext,
        byte[] solrXml,
        SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
        SortedMap<Class,String> extraRequestFilters,
        org.apache.solr.client.solrj.embedded.SSLConfig sslConfig,
        ZkTestServer zkTestServer)
          throws Exception

Throws:

Exception

newNodeName

public String newNodeName()

getZkServer

public ZkTestServer getZkServer()

Returns:

ZooKeeper server used by the MiniCluster

getJettySolrRunners

public List<org.apache.solr.client.solrj.embedded.JettySolrRunner> getJettySolrRunners()

Returns:

Unmodifiable list of all the currently started Solr Jettys.

startJettySolrRunner

public org.apache.solr.client.solrj.embedded.JettySolrRunner startJettySolrRunner(String name,
                                                                         String hostContext,
                                                                         SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
                                                                         SortedMap<Class,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 org.apache.solr.client.solrj.embedded.JettySolrRunner startJettySolrRunner(String name,
                                                                         String hostContext,
                                                                         SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
                                                                         SortedMap<Class,String> extraRequestFilters,
                                                                         org.apache.solr.client.solrj.embedded.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

stopJettySolrRunner

public org.apache.solr.client.solrj.embedded.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

uploadConfigDir

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

Throws:

IOException

org.apache.zookeeper.KeeperException

InterruptedException

getSolrClient

public org.apache.solr.client.solrj.impl.CloudSolrServer getSolrClient()

createCollection

public org.apache.solr.common.util.NamedList<Object> createCollection(String name,
                                                             int numShards,
                                                             int replicationFactor,
                                                             String configName,
                                                             Map<String,String> collectionProperties)
                                                               throws org.apache.solr.client.solrj.SolrServerException,
                                                                      IOException

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

createCollection

public org.apache.solr.common.util.NamedList<Object> createCollection(String name,
                                                             int numShards,
                                                             int replicationFactor,
                                                             String configName,
                                                             String createNodeSet,
                                                             Map<String,String> collectionProperties)
                                                               throws org.apache.solr.client.solrj.SolrServerException,
                                                                      IOException

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

deleteCollection

public org.apache.solr.common.util.NamedList<Object> deleteCollection(String name)
                                                               throws org.apache.solr.client.solrj.SolrServerException,
                                                                      IOException

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

shutdown

public void shutdown()
              throws Exception

Shut down the cluster, including all Solr nodes and ZooKeeper

Throws:

Exception

getReplicaJetty

public org.apache.solr.client.solrj.embedded.JettySolrRunner getReplicaJetty(org.apache.solr.common.cloud.Replica replica)

Return the jetty that a particular replica resides on

getRandomJetty

public org.apache.solr.client.solrj.embedded.JettySolrRunner getRandomJetty(Random random)

Returns:

a randomly-selected Jetty