Package org.apache.bookkeeper.discover

Class ZKRegistrationClient

java.lang.Object

org.apache.bookkeeper.discover.ZKRegistrationClient

All Implemented Interfaces:

AutoCloseable, RegistrationClient

public class ZKRegistrationClient
extends Object
implements RegistrationClient

ZooKeeper based RegistrationClient.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	ZKRegistrationClient.WatchTask

Nested classes/interfaces inherited from interface org.apache.bookkeeper.discover.RegistrationClient

RegistrationClient.RegistrationListener

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final int	ZK_CONNECT_BACKOFF_MS

Constructor Summary

Constructors

Constructor	Description
ZKRegistrationClient(org.apache.zookeeper.ZooKeeper zk, String ledgersRootPath, ScheduledExecutorService scheduler, boolean bookieAddressTracking)

Method Summary

Modifier and Type	Method	Description
void	close()
(package private) static BookieServiceInfo	deserializeBookieServiceInfo(BookieId bookieId, byte[] bookieServiceInfo)
CompletableFuture<Versioned<Set<BookieId>>>	getAllBookies()	Get the list of all bookies identifiers.
CompletableFuture<Versioned<BookieServiceInfo>>	getBookieServiceInfo(BookieId bookieId)	Get detailed information about the services exposed by a Bookie.
CompletableFuture<Versioned<Set<BookieId>>>	getReadOnlyBookies()	Get the list of readonly bookie identifiers.
(package private) ZKRegistrationClient.WatchTask	getWatchReadOnlyBookiesTask()
(package private) ZKRegistrationClient.WatchTask	getWatchWritableBookiesTask()
CompletableFuture<Versioned<Set<BookieId>>>	getWritableBookies()	Get the list of writable bookie identifiers.
org.apache.zookeeper.ZooKeeper	getZk()
boolean	isBookieAddressTracking()
void	unwatchReadOnlyBookies(RegistrationClient.RegistrationListener listener)	Unwatch the changes of bookies.
void	unwatchWritableBookies(RegistrationClient.RegistrationListener listener)	Unwatch the changes of bookies.
CompletableFuture<Void>	watchReadOnlyBookies(RegistrationClient.RegistrationListener listener)	Watch the changes of bookies.
CompletableFuture<Void>	watchWritableBookies(RegistrationClient.RegistrationListener listener)	Watch the changes of bookies.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ZK_CONNECT_BACKOFF_MS

static final int ZK_CONNECT_BACKOFF_MS

See Also:

• Constant Field Values

Constructor Details

ZKRegistrationClient

public ZKRegistrationClient(org.apache.zookeeper.ZooKeeper zk,
 String ledgersRootPath,
 ScheduledExecutorService scheduler,
 boolean bookieAddressTracking)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RegistrationClient

isBookieAddressTracking

public boolean isBookieAddressTracking()

getZk

public org.apache.zookeeper.ZooKeeper getZk()

getWritableBookies

public CompletableFuture<Versioned<Set<BookieId>>> getWritableBookies()

Description copied from interface: RegistrationClient

Get the list of writable bookie identifiers.

Specified by:

getWritableBookies in interface RegistrationClient

Returns:

a future represents the list of writable bookies.

getAllBookies

public CompletableFuture<Versioned<Set<BookieId>>> getAllBookies()

Description copied from interface: RegistrationClient

Get the list of all bookies identifiers.

Specified by:

getAllBookies in interface RegistrationClient

Returns:

a future represents the list of all bookies.

getReadOnlyBookies

public CompletableFuture<Versioned<Set<BookieId>>> getReadOnlyBookies()

Description copied from interface: RegistrationClient

Get the list of readonly bookie identifiers.

Specified by:

getReadOnlyBookies in interface RegistrationClient

Returns:

a future represents the list of readonly bookies.

getBookieServiceInfo

public CompletableFuture<Versioned<BookieServiceInfo>> getBookieServiceInfo(BookieId bookieId)

Description copied from interface: RegistrationClient

Get detailed information about the services exposed by a Bookie. For old bookies it is expected to return an empty BookieServiceInfo structure.

Specified by:

getBookieServiceInfo in interface RegistrationClient

Parameters:

bookieId - this is the id of the bookie, it can be computed from a BookieId

Returns:

a future represents the available information.

deserializeBookieServiceInfo

static BookieServiceInfo deserializeBookieServiceInfo(BookieId bookieId,
 byte[] bookieServiceInfo)
                                               throws IOException

Throws:

IOException

watchWritableBookies

public CompletableFuture<Void> watchWritableBookies(RegistrationClient.RegistrationListener listener)

Description copied from interface: RegistrationClient

Watch the changes of bookies.

The topology changes of bookies will be propagated to the provided listener.

Specified by:

watchWritableBookies in interface RegistrationClient

Parameters:

listener - listener to receive the topology changes of bookies.

Returns:

a future which completes when the bookies have been read for the first time

unwatchWritableBookies

public void unwatchWritableBookies(RegistrationClient.RegistrationListener listener)

Description copied from interface: RegistrationClient

Unwatch the changes of bookies.

Specified by:

unwatchWritableBookies in interface RegistrationClient

Parameters:

listener - listener to receive the topology changes of bookies.

watchReadOnlyBookies

public CompletableFuture<Void> watchReadOnlyBookies(RegistrationClient.RegistrationListener listener)

Description copied from interface: RegistrationClient

Watch the changes of bookies.

The topology changes of bookies will be propagated to the provided listener.

Specified by:

watchReadOnlyBookies in interface RegistrationClient

Parameters:

listener - listener to receive the topology changes of bookies.

Returns:

a future which completes when the bookies have been read for the first time

unwatchReadOnlyBookies

public void unwatchReadOnlyBookies(RegistrationClient.RegistrationListener listener)

Description copied from interface: RegistrationClient

Unwatch the changes of bookies.

Specified by:

unwatchReadOnlyBookies in interface RegistrationClient

Parameters:

listener - listener to receive the topology changes of bookies.

getWatchWritableBookiesTask

ZKRegistrationClient.WatchTask getWatchWritableBookiesTask()

getWatchReadOnlyBookiesTask

ZKRegistrationClient.WatchTask getWatchReadOnlyBookiesTask()