Package org.apache.pulsar.client.admin

Interface Bookies

public interface Bookies

Admin interface for bookies rack placement management.

Method Summary

Modifier and Type	Method	Description
void	deleteBookieRackInfo(String bookieAddress)	Remove rack placement information for a specific bookie in the cluster.
CompletableFuture<Void>	deleteBookieRackInfoAsync(String bookieAddress)	Remove rack placement information for a specific bookie in the cluster asynchronously.
BookieInfo	getBookieRackInfo(String bookieAddress)	Gets the rack placement information for a specific bookie in the cluster.
CompletableFuture<BookieInfo>	getBookieRackInfoAsync(String bookieAddress)	Gets the rack placement information for a specific bookie in the cluster asynchronously.
BookiesClusterInfo	getBookies()	Gets discovery information for all the bookies in the cluster.
CompletableFuture<BookiesClusterInfo>	getBookiesAsync()	Gets discovery information for all the bookies in the cluster asynchronously.
BookiesRackConfiguration	getBookiesRackInfo()	Gets the rack placement information for all the bookies in the cluster.
CompletableFuture<BookiesRackConfiguration>	getBookiesRackInfoAsync()	Gets the rack placement information for all the bookies in the cluster asynchronously.
void	updateBookieRackInfo(String bookieAddress, String group, BookieInfo bookieInfo)	Updates the rack placement information for a specific bookie in the cluster.
CompletableFuture<Void>	updateBookieRackInfoAsync(String bookieAddress, String group, BookieInfo bookieInfo)	Updates the rack placement information for a specific bookie in the cluster asynchronously.

Method Details

getBookiesRackInfo

BookiesRackConfiguration getBookiesRackInfo()
                                     throws PulsarAdminException

Gets the rack placement information for all the bookies in the cluster.

Throws:

PulsarAdminException

getBookiesRackInfoAsync

CompletableFuture<BookiesRackConfiguration> getBookiesRackInfoAsync()

Gets the rack placement information for all the bookies in the cluster asynchronously.

getBookies

BookiesClusterInfo getBookies()
                       throws PulsarAdminException

Gets discovery information for all the bookies in the cluster.

Throws:

PulsarAdminException

getBookiesAsync

CompletableFuture<BookiesClusterInfo> getBookiesAsync()

Gets discovery information for all the bookies in the cluster asynchronously.

getBookieRackInfo

BookieInfo getBookieRackInfo(String bookieAddress)
                      throws PulsarAdminException

Gets the rack placement information for a specific bookie in the cluster.

Throws:

PulsarAdminException

getBookieRackInfoAsync

CompletableFuture<BookieInfo> getBookieRackInfoAsync(String bookieAddress)

Gets the rack placement information for a specific bookie in the cluster asynchronously.

deleteBookieRackInfo

void deleteBookieRackInfo(String bookieAddress)
                   throws PulsarAdminException

Remove rack placement information for a specific bookie in the cluster.

Throws:

PulsarAdminException

deleteBookieRackInfoAsync

CompletableFuture<Void> deleteBookieRackInfoAsync(String bookieAddress)

Remove rack placement information for a specific bookie in the cluster asynchronously.

updateBookieRackInfo

void updateBookieRackInfo(String bookieAddress,
 String group,
 BookieInfo bookieInfo)
                   throws PulsarAdminException

Updates the rack placement information for a specific bookie in the cluster.

Throws:

PulsarAdminException

updateBookieRackInfoAsync

CompletableFuture<Void> updateBookieRackInfoAsync(String bookieAddress,
 String group,
 BookieInfo bookieInfo)

Updates the rack placement information for a specific bookie in the cluster asynchronously.