Package | Description |
---|---|
org.apache.zookeeper | |
org.apache.zookeeper.server |
ZooKeeper server theory of operation
ZooKeeperServer is designed to work in standalone mode and also
be extensible so that it can be used to implement the quorum based
version of ZooKeeper.
|
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 © 2017 The Apache Software Foundation