com.netflix.curator.test

Class TestingCluster

java.lang.Object

com.netflix.curator.test.TestingCluster

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class TestingCluster
extends java.lang.Object
implements java.io.Closeable

manages an internally running ensemble of ZooKeeper servers. FOR TESTING PURPOSES ONLY

Constructor Summary

Constructors

Constructor and Description
TestingCluster(java.util.Collection<InstanceSpec> specs) Creates an ensemble using the given server specs
TestingCluster(InstanceSpec... specs) Creates an ensemble using the given server specs
TestingCluster(int instanceQty) Creates an ensemble comprised of n servers.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Shutdown the ensemble, free resources, etc.
InstanceSpec	findConnectionInstance(org.apache.zookeeper.ZooKeeper client) Given a ZooKeeper instance, returns which server it is connected to
java.lang.String	getConnectString() Returns the connection string to pass to the ZooKeeper constructor
java.util.Collection<InstanceSpec>	getInstances() Returns the set of servers in the ensemble
boolean	killServer(InstanceSpec instance) Kills the given server.
boolean	restartServer(InstanceSpec instance) Restart the given server of the cluster
void	start() Start the ensemble.
void	stop() Shutdown the ensemble WITHOUT freeing resources, etc.

Methods inherited from class java.lang.Object

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

Constructor Detail

TestingCluster

public TestingCluster(int instanceQty)

Creates an ensemble comprised of n servers. Each server will use a temp directory and random ports

Parameters:

instanceQty - number of servers to create in the ensemble

TestingCluster

public TestingCluster(InstanceSpec... specs)

Creates an ensemble using the given server specs

Parameters:

specs - the server specs

TestingCluster

public TestingCluster(java.util.Collection<InstanceSpec> specs)

Creates an ensemble using the given server specs

Parameters:

specs - the server specs

Method Detail

getInstances

public java.util.Collection<InstanceSpec> getInstances()

Returns the set of servers in the ensemble

Returns:

set of servers

getConnectString

public java.lang.String getConnectString()

Returns the connection string to pass to the ZooKeeper constructor

Returns:

connection string

start

public void start()
           throws java.lang.Exception

Start the ensemble. The cluster must be started before use.

Throws:

java.lang.Exception - errors

stop

public void stop()
          throws java.io.IOException

Shutdown the ensemble WITHOUT freeing resources, etc.

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Shutdown the ensemble, free resources, etc. If temp directories were used, they are deleted. You should call this in a finally block.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException - errors

killServer

public boolean killServer(InstanceSpec instance)
                   throws java.lang.Exception

Kills the given server. This simulates the server unexpectedly crashing

Parameters:

instance - server to kill

Returns:

true if the instance was found

Throws:

java.lang.Exception - errors

restartServer

public boolean restartServer(InstanceSpec instance)
                      throws java.lang.Exception

Restart the given server of the cluster

Parameters:

instance - server instance

Returns:

true of the server was found

Throws:

java.lang.Exception - errors

findConnectionInstance

public InstanceSpec findConnectionInstance(org.apache.zookeeper.ZooKeeper client)
                                    throws java.lang.Exception

Given a ZooKeeper instance, returns which server it is connected to

Parameters:

client - ZK instance

Returns:

the server

Throws:

java.lang.Exception - errors