Package org.apache.bookkeeper.meta

Interface MetadataClientDriver

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

ZKMetadataClientDriver

@LimitedPrivate
@Evolving
public interface MetadataClientDriver
extends AutoCloseable

Driver to manage all the metadata managers required by a bookkeeper client.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	MetadataClientDriver.SessionStateListener	State Listener on listening the metadata client session states.

Method Summary

Modifier and Type	Method	Description
void	close()
LayoutManager	getLayoutManager()	Return the layout manager.
LedgerManagerFactory	getLedgerManagerFactory()	Return the ledger manager factory used for accessing ledger metadata.
RegistrationClient	getRegistrationClient()	Return the registration client used for discovering registered bookies.
String	getScheme()	Get the scheme of the metadata driver.
MetadataClientDriver	initialize(ClientConfiguration conf, ScheduledExecutorService scheduler, StatsLogger statsLogger, Optional<Object> ctx)	Initialize the metadata driver.
default CompletableFuture<Boolean>	isHealthCheckEnabled()	Return health check is enable or disable.
default CompletableFuture<Boolean>	isMetadataServiceAvailable()	Return driver metadata service is available.
void	setSessionStateListener(MetadataClientDriver.SessionStateListener sessionStateListener)	sets session state listener.

Method Details

initialize

MetadataClientDriver initialize(ClientConfiguration conf,
 ScheduledExecutorService scheduler,
 StatsLogger statsLogger,
 Optional<Object> ctx)
                         throws MetadataException

Initialize the metadata driver.

Parameters:

conf - configuration

scheduler - scheduler

statsLogger - stats logger

ctx - optional context object passed in for initialization. currently it is an external zookeeper instance, which can be used for zookeeper based metadata implementation.

Returns:

metadata driver

Throws:

MetadataException - when fail to initialize the client driver.

getScheme

String getScheme()

Get the scheme of the metadata driver.

Returns:

the scheme of the metadata driver.

getRegistrationClient

RegistrationClient getRegistrationClient()

Return the registration client used for discovering registered bookies.

Returns:

the registration client used for discovering registered bookies.

getLedgerManagerFactory

LedgerManagerFactory getLedgerManagerFactory()
                                      throws MetadataException

Return the ledger manager factory used for accessing ledger metadata.

Returns:

the ledger manager factory used for accessing ledger metadata.

Throws:

MetadataException

getLayoutManager

LayoutManager getLayoutManager()

Return the layout manager.

Returns:

the layout manager.

close

void close()

Specified by:

close in interface AutoCloseable

setSessionStateListener

void setSessionStateListener(MetadataClientDriver.SessionStateListener sessionStateListener)

sets session state listener.

Parameters:

sessionStateListener - listener listening on metadata client session states.

isHealthCheckEnabled

default CompletableFuture<Boolean> isHealthCheckEnabled()

Return health check is enable or disable.

Returns:

true if health check is enable, otherwise false.

isMetadataServiceAvailable

default CompletableFuture<Boolean> isMetadataServiceAvailable()

Return driver metadata service is available.

Returns:

the metadata service is available.