Package org.apache.bookkeeper.client
Class BookieInfoReader
java.lang.Object
org.apache.bookkeeper.client.BookieInfoReader
A utility class to read
BookieInfoReader.BookieInfo from bookies.
NOTE: This class is tended to be used by this project only. External users should not rely on it directly.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classA class represents the information (e.g.static enumTracks whether there is an execution in progress as well as whether another is pending. -
Constructor Summary
ConstructorsConstructorDescriptionBookieInfoReader(BookKeeper bk, ClientConfiguration conf, ScheduledExecutorService scheduler) -
Method Summary
Modifier and TypeMethodDescription(package private) voidavailableBookiesChanged(Set<BookieId> updatedBookiesList) (package private) Map<BookieId,BookieInfoReader.BookieInfo> getFreeDiskSpace(BookieId bookie) Method to allow tests to block until bookie info is available.(package private) voidPerforms scan described by instanceState using the cached bookie information in bookieInfoMap.(package private) voidonExit()voidstart()
-
Constructor Details
-
BookieInfoReader
BookieInfoReader(BookKeeper bk, ClientConfiguration conf, ScheduledExecutorService scheduler)
-
-
Method Details
-
start
public void start() -
availableBookiesChanged
-
getFreeDiskSpace
Method to allow tests to block until bookie info is available.- Parameters:
bookie- to lookup- Returns:
- None if absent, free disk space if present
-
getReadWriteBookieInfo
void getReadWriteBookieInfo()Performs scan described by instanceState using the cached bookie information in bookieInfoMap. -
onExit
void onExit() -
getBookieInfo
- Throws:
BKExceptionInterruptedException
-