Added Constructors |
ZooKeeper(String, int, Watcher, boolean)
|
To create a ZooKeeper client object the application needs to pass a connection string containing a comma separated list of host:port pairs each corresponding to a ZooKeeper server. |
ZooKeeper(String, int, Watcher, boolean, HostProvider)
|
To create a ZooKeeper client object the application needs to pass a connection string containing a comma separated list of host:port pairs each corresponding to a ZooKeeper server. |
ZooKeeper(String, int, Watcher, boolean, HostProvider, ZKClientConfig)
|
To create a ZooKeeper client object the application needs to pass a connection string containing a comma separated list of host:port pairs each corresponding to a ZooKeeper server. |
ZooKeeper(String, int, Watcher, boolean, ZKClientConfig)
|
To create a ZooKeeper client object the application needs to pass a connection string containing a comma separated list of host:port pairs each corresponding to a ZooKeeper server. |
ZooKeeper(String, int, Watcher, long, byte[], boolean)
|
To create a ZooKeeper client object the application needs to pass a connection string containing a comma separated list of host:port pairs each corresponding to a ZooKeeper server. |
ZooKeeper(String, int, Watcher, long, byte[], boolean, HostProvider)
|
To create a ZooKeeper client object the application needs to pass a connection string containing a comma separated list of host:port pairs each corresponding to a ZooKeeper server. |
ZooKeeper(String, int, Watcher, ZKClientConfig)
|
To create a ZooKeeper client object the application needs to pass a connection string containing a comma separated list of host:port pairs each corresponding to a ZooKeeper server. |
Added Methods |
String create(String, byte[], List, CreateMode, Stat)
|
Create a node with the given path and returns the Stat of that node. |
String create(String, byte[], List, CreateMode, Stat, long)
|
same as byte[ List CreateMode Stat)} but allows for specifying a TTL when mode is CreateMode#PERSISTENT_WITH_TTL or CreateMode#PERSISTENT_SEQUENTIAL_WITH_TTL If the znode has not been modified within the given TTL it will be deleted once it has no children. |
void create(String, byte[], List, CreateMode, Create2Callback, Object)
|
The asynchronous version of create. |
void create(String, byte[], List, CreateMode, Create2Callback, Object, long)
|
The asynchronous version of create with ttl. |
ZKWatchManager defaultWatchManager()
|
|
List getChildWatches()
|
|
List getChildren(String, boolean, Stat)
|
For the given znode path return the stat and children list. |
List getChildren(String, Watcher, Stat)
|
For the given znode path return the stat and children list. |
void getChildren(String, boolean, Children2Callback, Object)
|
The asynchronous version of getChildren. |
void getChildren(String, Watcher, Children2Callback, Object)
|
The asynchronous version of getChildren. |
ZKClientConfig getClientConfig()
|
|
byte[] getConfig(boolean, Stat)
|
Return the last committed configuration (as known to the server to which the client is connected) and the stat of the configuration. |
byte[] getConfig(Watcher, Stat)
|
Return the last committed configuration (as known to the server to which the client is connected) and the stat of the configuration. |
void getConfig(boolean, DataCallback, Object)
|
The Asynchronous version of getConfig. |
void getConfig(Watcher, DataCallback, Object)
|
The asynchronous version of getConfig. |
List getDataWatches()
|
|
List getExistWatches()
|
|
ZooKeeperSaslClient getSaslClient()
|
|
int getSessionTimeout()
|
The negotiated session timeout for this ZooKeeper client instance. |
Testable getTestable()
|
|
byte[] internalReconfig(String, String, String, long, Stat)
|
|
byte[] internalReconfig(List, List, List, long, Stat)
|
|
void internalReconfig(String, String, String, long, DataCallback, Object)
|
|
void internalReconfig(List, List, List, long, DataCallback, Object)
|
|
List multi(Iterable )
|
Executes multiple ZooKeeper operations or none of them. |
void multi(Iterable, MultiCallback, Object)
|
The asynchronous version of multi. |
List multiInternal(MultiTransactionRecord )
|
|
void multiInternal(MultiTransactionRecord, MultiCallback, Object)
|
|
byte[] reconfig(String, String, String, long, Stat)
|
@deprecated instead use the reconfigure() methods instead in org.apache.zookeeper.admin.ZooKeeperAdmin |
byte[] reconfig(List, List, List, long, Stat)
|
@deprecated instead use the reconfigure() methods instead in org.apache.zookeeper.admin.ZooKeeperAdmin |
void reconfig(String, String, String, long, DataCallback, Object)
|
@deprecated instead use the reconfigure() methods instead in org.apache.zookeeper.admin.ZooKeeperAdmin |
void reconfig(List, List, List, long, DataCallback, Object)
|
@deprecated instead use the reconfigure() methods instead in org.apache.zookeeper.admin.ZooKeeperAdmin |
void removeAllWatches(String, WatcherType, boolean)
|
For the given znode path removes all the registered watchers of given watcherType. |
void removeAllWatches(String, WatcherType, boolean, VoidCallback, Object)
|
The asynchronous version of removeAllWatches. |
void removeWatches(String, Watcher, WatcherType, boolean)
|
For the given znode path removes the specified watcher of given watcherType. |
void removeWatches(String, Watcher, WatcherType, boolean, VoidCallback, Object)
|
The asynchronous version of removeWatches. |
SocketAddress testableLocalSocketAddress()
|
Returns the local address to which the socket is bound. |
SocketAddress testableRemoteSocketAddress()
|
Returns the address to which the socket is connected. |
boolean testableWaitForShutdown(int )
|
Wait up to wait milliseconds for the underlying threads to shutdown. |
String toString()
|
String representation of this ZooKeeper client. |
Transaction transaction()
|
A Transaction is a thin wrapper on the #multi method which provides a builder object that can be used to construct and commit an atomic set of operations. |
void updateServerList(String )
|
This function allows a client to update the connection string by providing a new comma separated list of host:port pairs each corresponding to a ZooKeeper server. |