Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.linkedin.zookeeper.client
Class AbstractZooKeeper

java.lang.Object
  extended by org.linkedin.zookeeper.client.AbstractZooKeeper
All Implemented Interfaces:
IZooKeeper
Direct Known Subclasses:
AbstractZKClient
public abstract class AbstractZooKeeper
extends java.lang.Object
implements IZooKeeper

Base abstract class which delegate all calls to another IZooKeeper implementation and ajusts the path variable. Handle chroot as well.

Field Summary
static org.slf4j.Logger log
           
static java.lang.String MODULE
           
 
Constructor Summary
AbstractZooKeeper()
          Constructor
AbstractZooKeeper(java.lang.String chroot)
          Constructor
 
Method Summary
 void addAuthInfo(java.lang.String scheme, byte[] auth)
           
protected  java.lang.String adjustPath(java.lang.String path)
           
static java.lang.String adjustPath(java.lang.String path, java.lang.String chroot)
           
 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()
           
protected abstract  IZooKeeper getZk()
           
 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

AbstractZooKeeper

public AbstractZooKeeper()
Constructor

AbstractZooKeeper

public AbstractZooKeeper(java.lang.String chroot)
Constructor

Method Detail

adjustPath

public static java.lang.String adjustPath(java.lang.String path,
                                          java.lang.String chroot)

adjustPath

protected java.lang.String adjustPath(java.lang.String path)

addAuthInfo

public void addAuthInfo(java.lang.String scheme,
                        byte[] auth)
Specified by:
addAuthInfo in interface IZooKeeper

getZk

protected abstract IZooKeeper getZk()

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
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD