Package | Description |
---|---|
org.apache.zookeeper | |
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.upgrade |
Modifier and Type | Method and Description |
---|---|
Set<Watcher> |
ClientWatchManager.materialize(Watcher.Event.KeeperState state,
Watcher.Event.EventType type,
String path)
Return a set of watchers that should be notified of the event.
|
Modifier and Type | Method and Description |
---|---|
Stat |
ZooKeeper.exists(String path,
Watcher watcher)
Return the stat of the node of the given path.
|
void |
ZooKeeper.exists(String path,
Watcher watcher,
AsyncCallback.StatCallback cb,
Object ctx)
The asynchronous version of exists.
|
List<String> |
ZooKeeper.getChildren(String path,
Watcher watcher)
Return the list of the children of the node of the given path.
|
void |
ZooKeeper.getChildren(String path,
Watcher watcher,
AsyncCallback.Children2Callback cb,
Object ctx)
The asynchronous version of getChildren.
|
void |
ZooKeeper.getChildren(String path,
Watcher watcher,
AsyncCallback.ChildrenCallback cb,
Object ctx)
The asynchronous version of getChildren.
|
List<String> |
ZooKeeper.getChildren(String path,
Watcher watcher,
Stat stat)
For the given znode path return the stat and children list.
|
void |
ZooKeeper.getData(String path,
Watcher watcher,
AsyncCallback.DataCallback cb,
Object ctx)
The asynchronous version of getData.
|
byte[] |
ZooKeeper.getData(String path,
Watcher watcher,
Stat stat)
Return the data and the stat of the node of the given path.
|
void |
ZooKeeper.register(Watcher watcher)
Specify the default watcher for the connection (overrides the one
specified during construction).
|
Constructor and Description |
---|
ZooKeeper(String connectString,
int sessionTimeout,
Watcher watcher)
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 connectString,
int sessionTimeout,
Watcher watcher,
boolean canBeReadOnly)
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 connectString,
int sessionTimeout,
Watcher watcher,
long sessionId,
byte[] sessionPasswd)
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 connectString,
int sessionTimeout,
Watcher watcher,
long sessionId,
byte[] sessionPasswd,
boolean canBeReadOnly)
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.
|
Modifier and Type | Class and Description |
---|---|
class |
NettyServerCnxn |
class |
NIOServerCnxn
This class handles communication with clients using NIO.
|
class |
ServerCnxn
Interface to a Server connection - represents a connection from a client
to the server.
|
Modifier and Type | Method and Description |
---|---|
Set<Watcher> |
WatchManager.triggerWatch(String path,
Watcher.Event.EventType type) |
Set<Watcher> |
WatchManager.triggerWatch(String path,
Watcher.Event.EventType type,
Set<Watcher> supress) |
Modifier and Type | Method and Description |
---|---|
void |
WatchManager.addWatch(String path,
Watcher watcher) |
List<String> |
DataTree.getChildren(String path,
Stat stat,
Watcher watcher) |
List<String> |
ZKDatabase.getChildren(String path,
Stat stat,
Watcher watcher)
get children list for this path
|
byte[] |
DataTree.getData(String path,
Stat stat,
Watcher watcher) |
byte[] |
ZKDatabase.getData(String path,
Stat stat,
Watcher watcher)
get data and stat for a path
|
void |
DataTree.removeCnxn(Watcher watcher) |
void |
WatchManager.removeWatcher(Watcher watcher) |
void |
DataTree.setWatches(long relativeZxid,
List<String> dataWatches,
List<String> existWatches,
List<String> childWatches,
Watcher watcher) |
void |
ZKDatabase.setWatches(long relativeZxid,
List<String> dataWatches,
List<String> existWatches,
List<String> childWatches,
Watcher watcher)
set watches on the datatree
|
Stat |
DataTree.statNode(String path,
Watcher watcher) |
Modifier and Type | Method and Description |
---|---|
Set<Watcher> |
WatchManager.triggerWatch(String path,
Watcher.Event.EventType type,
Set<Watcher> supress) |
Modifier and Type | Method and Description |
---|---|
ArrayList<String> |
DataTreeV1.getChildren(String path,
Stat stat,
Watcher watcher) |
byte[] |
DataTreeV1.getData(String path,
Stat stat,
Watcher watcher) |
void |
DataTreeV1.removeCnxn(Watcher watcher) |
Stat |
DataTreeV1.statNode(String path,
Watcher watcher) |
Copyright © 2013 The Apache Software Foundation