public class BookieInfoReader
extends java.lang.Object
BookieInfoReader.BookieInfo
from bookies.
NOTE: This class is tended to be used by this project only. External users should not rely on it directly.
Modifier and Type | Class and Description |
---|---|
static class |
BookieInfoReader.BookieInfo
A class represents the information (e.g.
|
static class |
BookieInfoReader.State
Tracks whether there is an execution in progress as well as whether
another is pending.
|
Constructor and Description |
---|
BookieInfoReader(BookKeeper bk,
ClientConfiguration conf,
java.util.concurrent.ScheduledExecutorService scheduler) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
availableBookiesChanged(java.util.Set<org.apache.bookkeeper.net.BookieSocketAddress> updatedBookiesList) |
(package private) java.util.Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> |
getBookieInfo() |
(package private) java.util.Optional<java.lang.Long> |
getFreeDiskSpace(org.apache.bookkeeper.net.BookieSocketAddress bookie)
Method to allow tests to block until bookie info is available.
|
(package private) void |
getReadWriteBookieInfo()
Performs scan described by instanceState using the cached bookie information
in bookieInfoMap.
|
(package private) void |
onExit() |
void |
start() |
BookieInfoReader(BookKeeper bk, ClientConfiguration conf, java.util.concurrent.ScheduledExecutorService scheduler)
public void start()
void availableBookiesChanged(java.util.Set<org.apache.bookkeeper.net.BookieSocketAddress> updatedBookiesList)
java.util.Optional<java.lang.Long> getFreeDiskSpace(org.apache.bookkeeper.net.BookieSocketAddress bookie)
bookie
- to lookupvoid getReadWriteBookieInfo()
void onExit()
java.util.Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> getBookieInfo() throws BKException, java.lang.InterruptedException
BKException
java.lang.InterruptedException
Copyright © 2011–2020 The Apache Software Foundation. All rights reserved.