org.apache.hadoop.hbase.zookeeper

Class MiniZooKeeperCluster

java.lang.Object

org.apache.hadoop.hbase.zookeeper.MiniZooKeeperCluster

@InterfaceAudience.Public
public class MiniZooKeeperCluster
extends Object

TODO: Most of the code in this class is ripped from ZooKeeper tests. Instead of redoing it, we should contribute updates to their code which let us more easily access testing helper objects.

Field Summary

Fields

Modifier and Type	Field and Description
static String	HOST
static String	LOOPBACK_HOST

Constructor Summary

Constructors

Constructor and Description
MiniZooKeeperCluster()
MiniZooKeeperCluster(org.apache.hadoop.conf.Configuration configuration)

Method Summary

Modifier and Type	Method and Description
void	addClientPort(int clientPort) Add a client port to the list.
Address	getAddress()
int	getBackupZooKeeperServerNum()
int	getClientPort()
int	getZooKeeperServerNum()
int	killCurrentActiveZooKeeperServer()
void	killOneBackupZooKeeperServer() Kill one back up ZK servers.
void	setDefaultClientPort(int clientPort)
void	setTickTime(int tickTime)
void	shutdown()
int	startup(File baseDir)
int	startup(File baseDir, int numZooKeeperServers)

Methods inherited from class java.lang.Object

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

Field Detail

LOOPBACK_HOST

public static final String LOOPBACK_HOST

HOST

public static final String HOST

Constructor Detail

MiniZooKeeperCluster

public MiniZooKeeperCluster()

MiniZooKeeperCluster

public MiniZooKeeperCluster(org.apache.hadoop.conf.Configuration configuration)

Method Detail

addClientPort

public void addClientPort(int clientPort)

Add a client port to the list.

Parameters:

clientPort - the specified port

setDefaultClientPort

public void setDefaultClientPort(int clientPort)

setTickTime

public void setTickTime(int tickTime)

getBackupZooKeeperServerNum

public int getBackupZooKeeperServerNum()

getZooKeeperServerNum

public int getZooKeeperServerNum()

startup

public int startup(File baseDir)
            throws IOException,
                   InterruptedException

Throws:

IOException

InterruptedException

startup

public int startup(File baseDir,
                   int numZooKeeperServers)
            throws IOException,
                   InterruptedException

Parameters:

baseDir - the base directory to use

numZooKeeperServers - the number of ZooKeeper servers

Returns:

ClientPort server bound to, -1 if there was a binding problem and we couldn't pick another port.

Throws:

IOException - if an operation fails during the startup

InterruptedException - if the startup fails

shutdown

public void shutdown()
              throws IOException

Throws:

IOException - if waiting for the shutdown of a server fails

killCurrentActiveZooKeeperServer

public int killCurrentActiveZooKeeperServer()
                                     throws IOException,
                                            InterruptedException

Returns:

clientPort return clientPort if there is another ZK backup can run when killing the current active; return -1, if there is no backups.

Throws:

IOException - if waiting for the shutdown of a server fails

InterruptedException

killOneBackupZooKeeperServer

public void killOneBackupZooKeeperServer()
                                  throws IOException,
                                         InterruptedException

Kill one back up ZK servers.

Throws:

IOException - if waiting for the shutdown of a server fails

InterruptedException

getClientPort

public int getClientPort()

getAddress

public Address getAddress()

Returns:

Address for this cluster instance.