com.konakart.zoo

Class KKZookeeper

java.lang.Object

com.konakart.zoo.KKZookeeper

public class KKZookeeper
extends java.lang.Object

KKZookeeper - for accessing Zookeepers

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.commons.logging.Log	log the log

Constructor Summary

Constructors

Constructor and Description
KKZookeeper() Constructor

Method Summary

Modifier and Type	Method and Description
void	close() Disconnect from the Zookeeper
org.apache.zookeeper.ZooKeeper	connect(java.lang.String host, int sessionTimeoutMS, int connectionTimeoutMS) Connect to the Zookeeper or Zookeeper ensemble.
java.lang.String	getSolrIP() Get a live Solr IP address (host:port).
java.util.List<java.lang.String>	getSolrIPs() Get a List of the live Solr IP addresses each in the form (host:port).
java.util.List<java.lang.String>	getSolrURLs() Get a List of the live Solr http URLs each in the form (http://host:port/).
org.apache.zookeeper.Watcher.Event.KeeperState	getState()
java.lang.String	getStatusString() For debugging the KKZookeeperConnect
void	setState(org.apache.zookeeper.Watcher.Event.KeeperState state)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static org.apache.commons.logging.Log log

the log

Constructor Detail

KKZookeeper

public KKZookeeper()

Constructor

Method Detail

connect

public org.apache.zookeeper.ZooKeeper connect(java.lang.String host,
                                              int sessionTimeoutMS,
                                              int connectionTimeoutMS)
                                       throws java.io.IOException,
                                              java.lang.InterruptedException,
                                              com.konakart.app.KKException

Connect to the Zookeeper or Zookeeper ensemble. Returns a ZooKeeper object if successful.

Parameters:

host - Zookeeper hosts string (IP addresses of the single Zookeeper or all of the Zookeepers in the ensemble)

sessionTimeoutMS - session timeout in milliseconds

connectionTimeoutMS - timeout in milliseconds to connect to Zookeeper ensemble

Returns:

a ZooKeeper object

Throws:

java.io.IOException - an unexpected IOException exception

java.lang.InterruptedException - an unexpected InterruptedException exception

com.konakart.app.KKException - thrown if there is a connection timeout

getSolrIPs

public java.util.List<java.lang.String> getSolrIPs()
                                            throws org.apache.zookeeper.KeeperException,
                                                   java.lang.InterruptedException

Get a List of the live Solr IP addresses each in the form (host:port). The live Solr IP addresses are retrieved from the live_nodes node.

Returns:

a List of Strings representing the live Solr addresses

Throws:

java.lang.InterruptedException - an unexpected InterruptedException exception

org.apache.zookeeper.KeeperException - an unexpected KeeperException exception

getSolrURLs

public java.util.List<java.lang.String> getSolrURLs()
                                             throws org.apache.zookeeper.KeeperException,
                                                    java.lang.InterruptedException

Get a List of the live Solr http URLs each in the form (http://host:port/). The live Solr IP addresses are retrieved from the live_nodes node.

Returns:

a List of Strings representing the live Solr URLs

Throws:

java.lang.InterruptedException - an unexpected InterruptedException exception

org.apache.zookeeper.KeeperException - an unexpected KeeperException exception

getSolrIP

public java.lang.String getSolrIP()
                           throws org.apache.zookeeper.KeeperException,
                                  java.lang.InterruptedException

Get a live Solr IP address (host:port). The live Solr IP addresses are retrieved from the live_nodes node and one of these is chosen at random to return.

Returns:

a String representing the selected live Solr IP address

Throws:

java.lang.InterruptedException - an unexpected InterruptedException exception

org.apache.zookeeper.KeeperException - an unexpected KeeperException exception

getStatusString

public java.lang.String getStatusString()

For debugging the KKZookeeperConnect

Returns:

a String representing the status of the KKZookeeperConnect

getState

public org.apache.zookeeper.Watcher.Event.KeeperState getState()

Returns:

the state

setState

public void setState(org.apache.zookeeper.Watcher.Event.KeeperState state)

Parameters:

state - the state to set

close

public void close()
           throws java.lang.InterruptedException

Disconnect from the Zookeeper

Throws:

java.lang.InterruptedException - an unexpected InterruptedException exception