Uses of Interface
org.apache.bookkeeper.common.util.Watcher

Packages that use Watcher

Package	Description
org.apache.bookkeeper.bookie	Provides a Bookie server that stores entries for clients.
org.apache.bookkeeper.bookie.storage.ldb	Classes related to DB based ledger storage.
org.apache.bookkeeper.common.util	defines the utilities for allocator used across the project.
org.apache.bookkeeper.proto	Classes related to the Bookkeeper protocol.

Uses of Watcher in org.apache.bookkeeper.bookie

Fields in org.apache.bookkeeper.bookie with type parameters of type Watcher

Modifier and Type	Field	Description
static final RecyclableArrayList.Recycler<Watcher<LastAddConfirmedUpdateNotification>>	LastAddConfirmedUpdateNotification.WATCHER_RECYCLER

Methods in org.apache.bookkeeper.bookie with parameters of type Watcher

Modifier and Type	Method	Description
void	Bookie.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
void	BookieImpl.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) void	FileInfo.cancelWaitForLastAddConfirmedUpdate(Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) void	IndexPersistenceMgr.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
void	InterleavedLedgerStorage.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
void	InterleavedStorageRegenerateIndexOp.DryRunLedgerCache.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
void	LedgerCache.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
void	LedgerCacheImpl.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) abstract void	LedgerDescriptor.cancelWaitForLastAddConfirmedUpdate(Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) void	LedgerDescriptorImpl.cancelWaitForLastAddConfirmedUpdate(Watcher<LastAddConfirmedUpdateNotification> watcher)
void	LedgerStorage.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)	Cancel a previous wait for last add confirmed update.
void	SortedLedgerStorage.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
boolean	Bookie.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
boolean	BookieImpl.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) boolean	FileInfo.waitForLastAddConfirmedUpdate(long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) boolean	IndexPersistenceMgr.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
boolean	InterleavedLedgerStorage.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
boolean	InterleavedStorageRegenerateIndexOp.DryRunLedgerCache.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
boolean	LedgerCache.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
boolean	LedgerCacheImpl.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) abstract boolean	LedgerDescriptor.waitForLastAddConfirmedUpdate(long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) boolean	LedgerDescriptorImpl.waitForLastAddConfirmedUpdate(long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
boolean	LedgerStorage.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)	Wait for last add confirmed update.
boolean	SortedLedgerStorage.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)

Uses of Watcher in org.apache.bookkeeper.bookie.storage.ldb

Methods in org.apache.bookkeeper.bookie.storage.ldb with parameters of type Watcher

Modifier and Type	Method	Description
void	DbLedgerStorage.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
void	SingleDirectoryDbLedgerStorage.cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) void	TransientLedgerInfo.cancelWaitForLastAddConfirmedUpdate(Watcher<LastAddConfirmedUpdateNotification> watcher)
boolean	DbLedgerStorage.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
boolean	SingleDirectoryDbLedgerStorage.waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) boolean	TransientLedgerInfo.waitForLastAddConfirmedUpdate(long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)

Uses of Watcher in org.apache.bookkeeper.common.util

Methods in org.apache.bookkeeper.common.util with parameters of type Watcher

Modifier and Type	Method	Description
boolean	Watchable.addWatcher(Watcher<T> w)	Adds an watcher to the set of watchers for this object, provided that it is not the same as some watcher already in the set.
boolean	Watchable.deleteWatcher(Watcher<T> w)	Deletes an watcher from the set of watcher of this object.

Constructor parameters in org.apache.bookkeeper.common.util with type arguments of type Watcher

Modifier	Constructor	Description
	Watchable(RecyclableArrayList.Recycler<Watcher<T>> recycler)	Construct an Watchable with zero watchers.

Uses of Watcher in org.apache.bookkeeper.proto

Classes in org.apache.bookkeeper.proto that implement Watcher

Modifier and Type	Class	Description
(package private) class	LongPollReadEntryProcessorV3	Processor handling long poll read entry request.