org.apache.zookeeper.server.watch

Interface IWatchManager

All Known Implementing Classes:

WatchManager, WatchManagerOptimized

public interface IWatchManager

Method Summary

Modifier and Type	Method and Description
boolean	addWatch(String path, Watcher watcher) Add watch to specific path.
default boolean	addWatch(String path, Watcher watcher, WatcherMode watcherMode) Add watch to specific path.
boolean	containsWatcher(String path, Watcher watcher) Checks the specified watcher exists for the given path.
void	dumpWatches(PrintWriter pwriter, boolean byPath) String representation of watches.
default int	getRecursiveWatchQty() Return the current number of recursive watchers
WatchesReport	getWatches() Returns a watch report.
WatchesPathReport	getWatchesByPath() Returns a watch report by path.
WatchesSummary	getWatchesSummary() Returns a watch summary.
boolean	removeWatcher(String path, Watcher watcher) Removes the specified watcher for the given path.
void	removeWatcher(Watcher watcher) The entry to remove the watcher when the cnxn is closed.
void	shutdown() Clean up the watch manager.
int	size() Get the size of watchers.
WatcherOrBitSet	triggerWatch(String path, Watcher.Event.EventType type) Distribute the watch event for the given path.
WatcherOrBitSet	triggerWatch(String path, Watcher.Event.EventType type, WatcherOrBitSet suppress) Distribute the watch event for the given path, but ignore those suppressed ones.

Method Detail

addWatch

boolean addWatch(String path,
                 Watcher watcher)

Add watch to specific path.

Parameters:

path - znode path

watcher - watcher object reference

Returns:

true if the watcher added is not already present

addWatch

default boolean addWatch(String path,
                         Watcher watcher,
                         WatcherMode watcherMode)

Add watch to specific path.

Parameters:

path - znode path

watcher - watcher object reference

watcherMode - the watcher mode to use

Returns:

true if the watcher added is not already present

containsWatcher

boolean containsWatcher(String path,
                        Watcher watcher)

Checks the specified watcher exists for the given path.

Parameters:

path - znode path

watcher - watcher object reference

Returns:

true if the watcher exists, false otherwise

removeWatcher

boolean removeWatcher(String path,
                      Watcher watcher)

Removes the specified watcher for the given path.

Parameters:

path - znode path

watcher - watcher object reference

Returns:

true if the watcher successfully removed, false otherwise

removeWatcher

void removeWatcher(Watcher watcher)

The entry to remove the watcher when the cnxn is closed.

Parameters:

watcher - watcher object reference

triggerWatch

WatcherOrBitSet triggerWatch(String path,
                             Watcher.Event.EventType type)

Distribute the watch event for the given path.

Parameters:

path - znode path

type - the watch event type

Returns:

the watchers have been notified

triggerWatch

WatcherOrBitSet triggerWatch(String path,
                             Watcher.Event.EventType type,
                             WatcherOrBitSet suppress)

Distribute the watch event for the given path, but ignore those suppressed ones.

Parameters:

path - znode path

type - the watch event type

suppress - the suppressed watcher set

Returns:

the watchers have been notified

size

int size()

Get the size of watchers.

Returns:

the watchers number managed in this class.

shutdown

void shutdown()

Clean up the watch manager.

getWatchesSummary

WatchesSummary getWatchesSummary()

Returns a watch summary.

Returns:

watch summary

See Also:

WatchesSummary

getWatches

WatchesReport getWatches()

Returns a watch report.

Returns:

watch report

See Also:

WatchesReport

getWatchesByPath

WatchesPathReport getWatchesByPath()

Returns a watch report by path.

Returns:

watch report

See Also:

WatchesPathReport

dumpWatches

void dumpWatches(PrintWriter pwriter,
                 boolean byPath)

String representation of watches. Warning, may be large!

Parameters:

pwriter - the writer to dump the watches

byPath - iff true output watches by paths, otw output watches by connection

getRecursiveWatchQty

default int getRecursiveWatchQty()

Return the current number of recursive watchers

Returns:

qty