Uses of Interface
org.apache.zookeeper.Watcher
Packages that use Watcher
Package
Description
ZooKeeper server theory of operation
-
Uses of Watcher in org.apache.zookeeper
Methods in org.apache.zookeeper that return types with arguments of type WatcherModifier and TypeMethodDescriptionZooKeeper.WatchRegistration.getWatches
(int rc) ClientWatchManager.materialize
(Watcher.Event.KeeperState state, Watcher.Event.EventType type, String path) Return a set of watchers that should be notified of the event.WatchDeregistration.unregister
(int rc) Unregistering watcher that was added on path.Methods in org.apache.zookeeper with parameters of type WatcherModifier and TypeMethodDescriptionvoid
ZooKeeper.addWatch
(String basePath, Watcher watcher, AddWatchMode mode) Add a watch to the given znode using the given mode.void
ZooKeeper.addWatch
(String basePath, Watcher watcher, AddWatchMode mode, AsyncCallback.VoidCallback cb, Object ctx) Async version ofZooKeeper.addWatch(String, Watcher, AddWatchMode)
(see it for details)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.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.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[]
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[]
Return the data and the stat of the node of the given path.void
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.Constructors in org.apache.zookeeper with parameters of type WatcherModifierConstructorDescriptionClientCnxn
(String chrootPath, HostProvider hostProvider, int sessionTimeout, ZKClientConfig clientConfig, Watcher defaultWatcher, org.apache.zookeeper.ClientCnxnSocket clientCnxnSocket, boolean canBeReadOnly) Creates a connection object.ClientCnxn
(String chrootPath, HostProvider hostProvider, int sessionTimeout, ZKClientConfig clientConfig, Watcher defaultWatcher, org.apache.zookeeper.ClientCnxnSocket clientCnxnSocket, long sessionId, byte[] sessionPasswd, boolean canBeReadOnly) Creates a connection object.WatchDeregistration
(String clientPath, Watcher watcher, Watcher.WatcherType watcherType, boolean local, org.apache.zookeeper.ZKWatchManager zkManager) WatchRegistration
(Watcher watcher, String clientPath) 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.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 hostProvider, 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 hostProvider, 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. -
Uses of Watcher in org.apache.zookeeper.admin
Constructors in org.apache.zookeeper.admin with parameters of type WatcherModifierConstructorDescriptionZooKeeperAdmin
(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, boolean canBeReadOnly, ZKClientConfig conf) 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. -
Uses of Watcher in org.apache.zookeeper.inspector.manager
Classes in org.apache.zookeeper.inspector.manager that implement WatcherModifier and TypeClassDescriptionclass
A Watcher which will re-add itself every time an event is fired -
Uses of Watcher in org.apache.zookeeper.retry
Methods in org.apache.zookeeper.retry with parameters of type WatcherModifier and TypeMethodDescriptionZooKeeperRetry.getChildren
(String path, Watcher watcher) byte[]
Constructors in org.apache.zookeeper.retry with parameters of type WatcherModifierConstructorDescriptionZooKeeperRetry
(String connectString, int sessionTimeout, Watcher watcher) ZooKeeperRetry
(String connectString, int sessionTimeout, Watcher watcher, long sessionId, byte[] sessionPasswd) -
Uses of Watcher in org.apache.zookeeper.server
Subinterfaces of Watcher in org.apache.zookeeper.serverClasses in org.apache.zookeeper.server that implement WatcherModifier and TypeClassDescriptionclass
A empty watcher implementation used in bench and unit test.class
class
This class handles communication with clients using NIO.class
Interface to a Server connection - represents a connection from a client to the server.Methods in org.apache.zookeeper.server with parameters of type WatcherModifier and TypeMethodDescriptionvoid
void
Add a watchboolean
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 datatreeDataTree.getChildren
(String path, Stat stat, Watcher watcher) ZKDatabase.getChildren
(String path, Stat stat, Watcher watcher) get children list for this pathbyte[]
byte[]
get data and stat for a pathvoid
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 datatreevoid
DataTree.setWatches
(long relativeZxid, List<String> dataWatches, List<String> existWatches, List<String> childWatches, List<String> persistentWatches, List<String> persistentRecursiveWatches, Watcher watcher) void
ZKDatabase.setWatches
(long relativeZxid, List<String> dataWatches, List<String> existWatches, List<String> childWatches, List<String> persistentWatches, List<String> persistentRecursiveWatches, Watcher watcher) set watches on the datatree -
Uses of Watcher in org.apache.zookeeper.server.controller
Classes in org.apache.zookeeper.server.controller that implement WatcherModifier and TypeClassDescriptionclass
Extension of NIOServerCnxn which can inject changes per controller commands. -
Uses of Watcher in org.apache.zookeeper.server.watch
Methods in org.apache.zookeeper.server.watch that return types with arguments of type WatcherModifier and TypeMethodDescriptionWatchManagerOptimized.getWatcher2PathesMap()
May cause OOM if there are lots of watches, might better to forbid it in this class.Methods in org.apache.zookeeper.server.watch with parameters of type WatcherModifier and TypeMethodDescriptionboolean
Add watch to specific path.default boolean
IWatchManager.addWatch
(String path, Watcher watcher, WatcherMode watcherMode) Add watch to specific path.boolean
boolean
WatchManager.addWatch
(String path, Watcher watcher, WatcherMode watcherMode) boolean
boolean
boolean
IWatchManager.containsWatcher
(String path, Watcher watcher) Checks the specified watcher exists for the given path.boolean
WatchManager.containsWatcher
(String path, Watcher watcher) boolean
WatchManagerOptimized.containsWatcher
(String path, Watcher watcher) Used in the OpCode.checkWatches, which is a read operation, since read and write requests are exclusively processed, we don't need to hold lock here.boolean
IWatchManager.removeWatcher
(String path, Watcher watcher) Removes the specified watcher for the given path.void
IWatchManager.removeWatcher
(Watcher watcher) The entry to remove the watcher when the cnxn is closed.boolean
WatchManager.removeWatcher
(String path, Watcher watcher) void
WatchManager.removeWatcher
(Watcher watcher) boolean
WatchManagerOptimized.removeWatcher
(String path, Watcher watcher) void
WatchManagerOptimized.removeWatcher
(Watcher watcher) Constructor parameters in org.apache.zookeeper.server.watch with type arguments of type Watcher -
Uses of Watcher in org.apache.zookeeper.test.system
Classes in org.apache.zookeeper.test.system that implement WatcherModifier and TypeClassDescriptionclass
This class starts up,class
This class doles out assignments to InstanceContainers that are registered to a ZooKeeper znode.class
The client that gets spawned for the SimpleSysTestclass
This does a basic system test.