org.linkedin.zookeeper.client
Class ZooKeeperImpl

java.lang.Object
  org.linkedin.zookeeper.client.ZooKeeperImpl

All Implemented Interfaces:

IZooKeeper

public class ZooKeeperImpl
extends java.lang.Object
implements IZooKeeper

Delegate all calls to ZooKeeper (and adjusts the exceptions).

Field Summary

static org.slf4j.Logger	log
static java.lang.String	MODULE

Constructor Summary

ZooKeeperImpl(org.apache.zookeeper.ZooKeeper zk)
Constructor

Method Summary

void	addAuthInfo(java.lang.String scheme, byte[] auth)
void	close()
java.lang.String	create(java.lang.String path, byte[] data, java.util.List<org.apache.zookeeper.data.ACL> acl, org.apache.zookeeper.CreateMode createMode)
void	create(java.lang.String path, byte[] data, java.util.List<org.apache.zookeeper.data.ACL> acl, org.apache.zookeeper.CreateMode createMode, org.apache.zookeeper.AsyncCallback.StringCallback cb, java.lang.Object ctx)
void	delete(java.lang.String path, int version)
void	delete(java.lang.String path, int version, org.apache.zookeeper.AsyncCallback.VoidCallback cb, java.lang.Object ctx)
org.apache.zookeeper.data.Stat	exists(java.lang.String path, boolean watch)
void	exists(java.lang.String path, boolean watch, org.apache.zookeeper.AsyncCallback.StatCallback cb, java.lang.Object ctx)
org.apache.zookeeper.data.Stat	exists(java.lang.String path, org.apache.zookeeper.Watcher watcher)
void	exists(java.lang.String path, org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.AsyncCallback.StatCallback cb, java.lang.Object ctx)
java.util.List<org.apache.zookeeper.data.ACL>	getACL(java.lang.String path, org.apache.zookeeper.data.Stat stat)
void	getACL(java.lang.String path, org.apache.zookeeper.data.Stat stat, org.apache.zookeeper.AsyncCallback.ACLCallback cb, java.lang.Object ctx)
java.util.List<java.lang.String>	getChildren(java.lang.String path, boolean watch)
void	getChildren(java.lang.String path, boolean watch, org.apache.zookeeper.AsyncCallback.Children2Callback cb, java.lang.Object ctx)
void	getChildren(java.lang.String path, boolean watch, org.apache.zookeeper.AsyncCallback.ChildrenCallback cb, java.lang.Object ctx)
java.util.List<java.lang.String>	getChildren(java.lang.String path, boolean watch, org.apache.zookeeper.data.Stat stat)
java.util.List<java.lang.String>	getChildren(java.lang.String path, org.apache.zookeeper.Watcher watcher)
void	getChildren(java.lang.String path, org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.AsyncCallback.Children2Callback cb, java.lang.Object ctx)
void	getChildren(java.lang.String path, org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.AsyncCallback.ChildrenCallback cb, java.lang.Object ctx)
java.util.List<java.lang.String>	getChildren(java.lang.String path, org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.data.Stat stat)
void	getData(java.lang.String path, boolean watch, org.apache.zookeeper.AsyncCallback.DataCallback cb, java.lang.Object ctx)
byte[]	getData(java.lang.String path, boolean watch, org.apache.zookeeper.data.Stat stat)
void	getData(java.lang.String path, org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.AsyncCallback.DataCallback cb, java.lang.Object ctx)
byte[]	getData(java.lang.String path, org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.data.Stat stat)
long	getSessionId()
byte[]	getSessionPasswd()
int	getSessionTimeout()
org.apache.zookeeper.ZooKeeper.States	getState()
void	register(org.apache.zookeeper.Watcher watcher)
org.apache.zookeeper.data.Stat	setACL(java.lang.String path, java.util.List<org.apache.zookeeper.data.ACL> acl, int version)
void	setACL(java.lang.String path, java.util.List<org.apache.zookeeper.data.ACL> acl, int version, org.apache.zookeeper.AsyncCallback.StatCallback cb, java.lang.Object ctx)
org.apache.zookeeper.data.Stat	setData(java.lang.String path, byte[] data, int version)
void	setData(java.lang.String path, byte[] data, int version, org.apache.zookeeper.AsyncCallback.StatCallback cb, java.lang.Object ctx)
void	sync(java.lang.String path, org.apache.zookeeper.AsyncCallback.VoidCallback cb, java.lang.Object ctx)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE

public static final java.lang.String MODULE

log

public static final org.slf4j.Logger log

Constructor Detail

ZooKeeperImpl

public ZooKeeperImpl(org.apache.zookeeper.ZooKeeper zk)

Constructor

Method Detail

addAuthInfo

public void addAuthInfo(java.lang.String scheme,
                        byte[] auth)

Specified by:

addAuthInfo in interface IZooKeeper

close

public void close()
           throws java.lang.InterruptedException

Specified by:

close in interface IZooKeeper

Throws:

java.lang.InterruptedException

create

public java.lang.String create(java.lang.String path,
                               byte[] data,
                               java.util.List<org.apache.zookeeper.data.ACL> acl,
                               org.apache.zookeeper.CreateMode createMode)
                        throws org.apache.zookeeper.KeeperException,
                               java.lang.InterruptedException

Specified by:

create in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

create

public void create(java.lang.String path,
                   byte[] data,
                   java.util.List<org.apache.zookeeper.data.ACL> acl,
                   org.apache.zookeeper.CreateMode createMode,
                   org.apache.zookeeper.AsyncCallback.StringCallback cb,
                   java.lang.Object ctx)

Specified by:

create in interface IZooKeeper

delete

public void delete(java.lang.String path,
                   int version)
            throws org.apache.zookeeper.KeeperException,
                   java.lang.InterruptedException

Specified by:

delete in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

delete

public void delete(java.lang.String path,
                   int version,
                   org.apache.zookeeper.AsyncCallback.VoidCallback cb,
                   java.lang.Object ctx)

Specified by:

delete in interface IZooKeeper

exists

public org.apache.zookeeper.data.Stat exists(java.lang.String path,
                                             boolean watch)
                                      throws org.apache.zookeeper.KeeperException,
                                             java.lang.InterruptedException

Specified by:

exists in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

exists

public void exists(java.lang.String path,
                   boolean watch,
                   org.apache.zookeeper.AsyncCallback.StatCallback cb,
                   java.lang.Object ctx)

Specified by:

exists in interface IZooKeeper

exists

public org.apache.zookeeper.data.Stat exists(java.lang.String path,
                                             org.apache.zookeeper.Watcher watcher)
                                      throws org.apache.zookeeper.KeeperException,
                                             java.lang.InterruptedException

Specified by:

exists in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

exists

public void exists(java.lang.String path,
                   org.apache.zookeeper.Watcher watcher,
                   org.apache.zookeeper.AsyncCallback.StatCallback cb,
                   java.lang.Object ctx)

Specified by:

exists in interface IZooKeeper

getACL

public java.util.List<org.apache.zookeeper.data.ACL> getACL(java.lang.String path,
                                                            org.apache.zookeeper.data.Stat stat)
                                                     throws org.apache.zookeeper.KeeperException,
                                                            java.lang.InterruptedException

Specified by:

getACL in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

getACL

public void getACL(java.lang.String path,
                   org.apache.zookeeper.data.Stat stat,
                   org.apache.zookeeper.AsyncCallback.ACLCallback cb,
                   java.lang.Object ctx)

Specified by:

getACL in interface IZooKeeper

getChildren

public java.util.List<java.lang.String> getChildren(java.lang.String path,
                                                    boolean watch)
                                             throws org.apache.zookeeper.KeeperException,
                                                    java.lang.InterruptedException

Specified by:

getChildren in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

getChildren

public void getChildren(java.lang.String path,
                        boolean watch,
                        org.apache.zookeeper.AsyncCallback.ChildrenCallback cb,
                        java.lang.Object ctx)

Specified by:

getChildren in interface IZooKeeper

getChildren

public java.util.List<java.lang.String> getChildren(java.lang.String path,
                                                    org.apache.zookeeper.Watcher watcher)
                                             throws org.apache.zookeeper.KeeperException,
                                                    java.lang.InterruptedException

Specified by:

getChildren in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

getChildren

public void getChildren(java.lang.String path,
                        org.apache.zookeeper.Watcher watcher,
                        org.apache.zookeeper.AsyncCallback.ChildrenCallback cb,
                        java.lang.Object ctx)

Specified by:

getChildren in interface IZooKeeper

getData

public void getData(java.lang.String path,
                    boolean watch,
                    org.apache.zookeeper.AsyncCallback.DataCallback cb,
                    java.lang.Object ctx)

Specified by:

getData in interface IZooKeeper

getData

public byte[] getData(java.lang.String path,
                      boolean watch,
                      org.apache.zookeeper.data.Stat stat)
               throws org.apache.zookeeper.KeeperException,
                      java.lang.InterruptedException

Specified by:

getData in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

getData

public void getData(java.lang.String path,
                    org.apache.zookeeper.Watcher watcher,
                    org.apache.zookeeper.AsyncCallback.DataCallback cb,
                    java.lang.Object ctx)

Specified by:

getData in interface IZooKeeper

getData

public byte[] getData(java.lang.String path,
                      org.apache.zookeeper.Watcher watcher,
                      org.apache.zookeeper.data.Stat stat)
               throws org.apache.zookeeper.KeeperException,
                      java.lang.InterruptedException

Specified by:

getData in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

getSessionId

public long getSessionId()

Specified by:

getSessionId in interface IZooKeeper

getSessionPasswd

public byte[] getSessionPasswd()

Specified by:

getSessionPasswd in interface IZooKeeper

getState

public org.apache.zookeeper.ZooKeeper.States getState()

Specified by:

getState in interface IZooKeeper

register

public void register(org.apache.zookeeper.Watcher watcher)

Specified by:

register in interface IZooKeeper

setACL

public org.apache.zookeeper.data.Stat setACL(java.lang.String path,
                                             java.util.List<org.apache.zookeeper.data.ACL> acl,
                                             int version)
                                      throws org.apache.zookeeper.KeeperException,
                                             java.lang.InterruptedException

Specified by:

setACL in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

setACL

public void setACL(java.lang.String path,
                   java.util.List<org.apache.zookeeper.data.ACL> acl,
                   int version,
                   org.apache.zookeeper.AsyncCallback.StatCallback cb,
                   java.lang.Object ctx)

Specified by:

setACL in interface IZooKeeper

setData

public org.apache.zookeeper.data.Stat setData(java.lang.String path,
                                              byte[] data,
                                              int version)
                                       throws org.apache.zookeeper.KeeperException,
                                              java.lang.InterruptedException

Specified by:

setData in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

setData

public void setData(java.lang.String path,
                    byte[] data,
                    int version,
                    org.apache.zookeeper.AsyncCallback.StatCallback cb,
                    java.lang.Object ctx)

Specified by:

setData in interface IZooKeeper

sync

public void sync(java.lang.String path,
                 org.apache.zookeeper.AsyncCallback.VoidCallback cb,
                 java.lang.Object ctx)

Specified by:

sync in interface IZooKeeper

getChildren

public void getChildren(java.lang.String path,
                        boolean watch,
                        org.apache.zookeeper.AsyncCallback.Children2Callback cb,
                        java.lang.Object ctx)

Specified by:

getChildren in interface IZooKeeper

getSessionTimeout

public int getSessionTimeout()

Specified by:

getSessionTimeout in interface IZooKeeper

getChildren

public java.util.List<java.lang.String> getChildren(java.lang.String path,
                                                    org.apache.zookeeper.Watcher watcher,
                                                    org.apache.zookeeper.data.Stat stat)
                                             throws org.apache.zookeeper.KeeperException,
                                                    java.lang.InterruptedException

Specified by:

getChildren in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

getChildren

public java.util.List<java.lang.String> getChildren(java.lang.String path,
                                                    boolean watch,
                                                    org.apache.zookeeper.data.Stat stat)
                                             throws org.apache.zookeeper.KeeperException,
                                                    java.lang.InterruptedException

Specified by:

getChildren in interface IZooKeeper

Throws:

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

getChildren

public void getChildren(java.lang.String path,
                        org.apache.zookeeper.Watcher watcher,
                        org.apache.zookeeper.AsyncCallback.Children2Callback cb,
                        java.lang.Object ctx)

Specified by:

getChildren in interface IZooKeeper