Package | Description |
---|---|
org.apache.zookeeper | |
org.apache.zookeeper.admin | |
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
Modifier and Type | Method and Description |
---|---|
protected abstract Map<String,Set<Watcher>> |
ZooKeeper.WatchRegistration.getWatches(int rc) |
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.
|
Map<Watcher.Event.EventType,Set<Watcher>> |
WatchDeregistration.unregister(int rc)
Unregistering watcher that was added on path.
|
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.getConfig(Watcher watcher,
AsyncCallback.DataCallback cb,
Object ctx)
The asynchronous version of getConfig.
|
byte[] |
ZooKeeper.getConfig(Watcher watcher,
Stat stat)
Return the last committed configuration (as known to the server to which the client is connected)
and the stat of the configuration.
|
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).
|
void |
ZooKeeper.removeWatches(String path,
Watcher watcher,
Watcher.WatcherType watcherType,
boolean local)
For the given znode path, removes the specified watcher of given
watcherType.
|
void |
ZooKeeper.removeWatches(String path,
Watcher watcher,
Watcher.WatcherType watcherType,
boolean local,
AsyncCallback.VoidCallback cb,
Object ctx)
The asynchronous version of removeWatches.
|
Constructor and Description |
---|
WatchDeregistration(String clientPath,
Watcher watcher,
Watcher.WatcherType watcherType,
boolean local,
org.apache.zookeeper.ZooKeeper.ZKWatchManager zkManager) |
WatchRegistration(Watcher watcher,
String clientPath) |
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,
boolean canBeReadOnly,
HostProvider aHostProvider)
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,
HostProvider aHostProvider,
ZKClientConfig clientConfig)
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,
ZKClientConfig conf)
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.
|
ZooKeeper(String connectString,
int sessionTimeout,
Watcher watcher,
long sessionId,
byte[] sessionPasswd,
boolean canBeReadOnly,
HostProvider aHostProvider)
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,
HostProvider aHostProvider,
ZKClientConfig clientConfig)
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,
ZKClientConfig conf)
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.
|
Constructor and Description |
---|
ZooKeeperAdmin(String connectString,
int sessionTimeout,
Watcher watcher)
Create a ZooKeeperAdmin object which is used to perform dynamic reconfiguration
operations.
|
ZooKeeperAdmin(String connectString,
int sessionTimeout,
Watcher watcher,
boolean canBeReadOnly)
Create a ZooKeeperAdmin object which is used to perform dynamic reconfiguration
operations.
|
ZooKeeperAdmin(String connectString,
int sessionTimeout,
Watcher watcher,
ZKClientConfig conf)
Create a ZooKeeperAdmin object which is used to perform dynamic reconfiguration
operations.
|
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 |
---|---|
boolean |
DataTree.containsWatcher(String path,
Watcher.WatcherType type,
Watcher watcher) |
boolean |
ZKDatabase.containsWatcher(String path,
Watcher.WatcherType type,
Watcher watcher)
Check whether the given watcher exists in datatree
|
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) |
boolean |
DataTree.removeWatch(String path,
Watcher.WatcherType type,
Watcher watcher) |
boolean |
ZKDatabase.removeWatch(String path,
Watcher.WatcherType type,
Watcher watcher)
Remove watch from the datatree
|
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) |
Copyright © 2008–2019 The Apache Software Foundation. All rights reserved.