Package org.apache.bookkeeper.client

Interface BookieWatcher

All Known Implementing Classes:

BookieWatcherImpl

public interface BookieWatcher

Watch for Bookkeeper cluster status.

Method Summary

Modifier and Type	Method	Description
Set<BookieId>	getAllBookies()
BookieAddressResolver	getBookieAddressResolver()
Set<BookieId>	getBookies()
Set<BookieId>	getReadOnlyBookies()
boolean	isBookieUnavailable(BookieId id)	Determine if a bookie should be considered unavailable.
List<BookieId>	newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata)	Create an ensemble with given ensembleSize and writeQuorumSize.
void	quarantineBookie(BookieId bookie)	Quarantine bookie so it will not be preferred to be chosen for new ensembles.
void	releaseAllQuarantinedBookies()	Release all quarantined bookies, let it can be chosen for new ensembles.
BookieId	replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> existingBookies, int bookieIdx, Set<BookieId> excludeBookies)	Choose a bookie to replace bookie bookieIdx in existingBookies.

Method Details

getBookies

Set<BookieId> getBookies()
                  throws BKException

Throws:

BKException

getAllBookies

Set<BookieId> getAllBookies()
                     throws BKException

Throws:

BKException

getReadOnlyBookies

Set<BookieId> getReadOnlyBookies()
                          throws BKException

Throws:

BKException

getBookieAddressResolver

BookieAddressResolver getBookieAddressResolver()

isBookieUnavailable

boolean isBookieUnavailable(BookieId id)

Determine if a bookie should be considered unavailable.

Parameters:

id - Bookie to check

Returns:

whether or not the given bookie is unavailable

newEnsemble

List<BookieId> newEnsemble(int ensembleSize,
 int writeQuorumSize,
 int ackQuorumSize,
 Map<String,byte[]> customMetadata)
                    throws BKException.BKNotEnoughBookiesException

Create an ensemble with given ensembleSize and writeQuorumSize.

Parameters:

ensembleSize - Ensemble Size

writeQuorumSize - Write Quorum Size

Returns:

list of bookies for new ensemble.

Throws:

BKException.BKNotEnoughBookiesException

replaceBookie

BookieId replaceBookie(int ensembleSize,
 int writeQuorumSize,
 int ackQuorumSize,
 Map<String,byte[]> customMetadata,
 List<BookieId> existingBookies,
 int bookieIdx,
 Set<BookieId> excludeBookies)
                throws BKException.BKNotEnoughBookiesException

Choose a bookie to replace bookie bookieIdx in existingBookies.

Parameters:

existingBookies - list of existing bookies.

bookieIdx - index of the bookie in the list to be replaced.

Returns:

the bookie to replace.

Throws:

BKException.BKNotEnoughBookiesException

quarantineBookie

void quarantineBookie(BookieId bookie)

Quarantine bookie so it will not be preferred to be chosen for new ensembles.

Parameters:

bookie -

releaseAllQuarantinedBookies

void releaseAllQuarantinedBookies()

Release all quarantined bookies, let it can be chosen for new ensembles.