Package org.apache.bookkeeper.meta

Class MetadataDrivers

java.lang.Object

org.apache.bookkeeper.meta.MetadataDrivers

public final class MetadataDrivers
extends Object

A driver manager for managing a set of metadata drivers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	MetadataDrivers.MetadataBookieDriverInfo
(package private) static class	MetadataDrivers.MetadataClientDriverInfo

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final String	BK_METADATA_BOOKIE_DRIVERS_PROPERTY
(package private) static final String	BK_METADATA_CLIENT_DRIVERS_PROPERTY
(package private) static final String	ZK_BOOKIE_DRIVER_CLASS
(package private) static final String	ZK_CLIENT_DRIVER_CLASS

Method Summary

Modifier and Type	Method	Description
static MetadataBookieDriver	getBookieDriver(String scheme)	Retrieve the bookie driver for scheme.
static MetadataBookieDriver	getBookieDriver(URI uri)	Retrieve the bookie driver for uri.
(package private) static ConcurrentMap<String,MetadataDrivers.MetadataBookieDriverInfo>	getBookieDrivers()
static MetadataClientDriver	getClientDriver(String scheme)	Retrieve the client driver for scheme.
static MetadataClientDriver	getClientDriver(URI uri)	Retrieve the client driver for uri.
(package private) static ConcurrentMap<String,MetadataDrivers.MetadataClientDriverInfo>	getClientDrivers()
(package private) static void	loadInitialDrivers()
static void	registerBookieDriver(String metadataBackendScheme, Class<? extends MetadataBookieDriver> driver)	Register the metadata bookie driver.
static void	registerBookieDriver(String metadataBackendScheme, Class<? extends MetadataBookieDriver> driver, boolean allowOverride)
static void	registerClientDriver(String metadataBackendScheme, Class<? extends MetadataClientDriver> driver)	Register the metadata client driver.
static void	registerClientDriver(String metadataBackendScheme, Class<? extends MetadataClientDriver> driver, boolean allowOverride)
static <T> T	runFunctionWithLedgerManagerFactory(ServerConfiguration conf, Function<LedgerManagerFactory,T> function)	Process the provided function with ledger manager factory resolved from the metadata service uri returned by AbstractConfiguration.getMetadataServiceUri().
static <T> T	runFunctionWithMetadataBookieDriver(ServerConfiguration conf, Function<MetadataBookieDriver,T> function)	Process the provided function with metadata bookie driver resolved from the metadata service uri returned by AbstractConfiguration.getMetadataServiceUri().
static <T> T	runFunctionWithMetadataClientDriver(ClientConfiguration conf, Function<MetadataClientDriver,T> function, ScheduledExecutorService executorService)	Process the provided function with metadata client driver resolved from the metadata service uri returned by AbstractConfiguration.getMetadataServiceUri().
static <T> T	runFunctionWithRegistrationManager(ServerConfiguration conf, Function<RegistrationManager,T> function)	Process the provided function with registration manager resolved from the metadata service uri returned by AbstractConfiguration.getMetadataServiceUri().

Methods inherited from class java.lang.Object

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

Field Details

ZK_CLIENT_DRIVER_CLASS

static final String ZK_CLIENT_DRIVER_CLASS

See Also:

• Constant Field Values

ZK_BOOKIE_DRIVER_CLASS

static final String ZK_BOOKIE_DRIVER_CLASS

See Also:

• Constant Field Values

BK_METADATA_CLIENT_DRIVERS_PROPERTY

static final String BK_METADATA_CLIENT_DRIVERS_PROPERTY

See Also:

• Constant Field Values

BK_METADATA_BOOKIE_DRIVERS_PROPERTY

static final String BK_METADATA_BOOKIE_DRIVERS_PROPERTY

See Also:

• Constant Field Values

Method Details

loadInitialDrivers

static void loadInitialDrivers()

registerClientDriver

public static void registerClientDriver(String metadataBackendScheme,
 Class<? extends MetadataClientDriver> driver)

Register the metadata client driver.

Parameters:

metadataBackendScheme - scheme of metadata backend.

driver - metadata client driver

registerClientDriver

public static void registerClientDriver(String metadataBackendScheme,
 Class<? extends MetadataClientDriver> driver,
 boolean allowOverride)

registerBookieDriver

public static void registerBookieDriver(String metadataBackendScheme,
 Class<? extends MetadataBookieDriver> driver)

Register the metadata bookie driver.

Parameters:

metadataBackendScheme - scheme of metadata backend.

driver - metadata bookie driver

registerBookieDriver

public static void registerBookieDriver(String metadataBackendScheme,
 Class<? extends MetadataBookieDriver> driver,
 boolean allowOverride)

getClientDriver

public static MetadataClientDriver getClientDriver(String scheme)

Retrieve the client driver for scheme.

Parameters:

scheme - the scheme for the metadata client driver

Returns:

the metadata client driver

Throws:

NullPointerException - when scheme is null

getClientDriver

public static MetadataClientDriver getClientDriver(URI uri)

Retrieve the client driver for uri.

Parameters:

uri - the metadata service uri

Returns:

the metadata client driver for uri

Throws:

NullPointerException - if the metadata service uri is null or doesn't have scheme or there is no namespace driver registered for the scheme

IllegalArgumentException - if the metadata service uri scheme is illegal

getBookieDriver

public static MetadataBookieDriver getBookieDriver(String scheme)

Retrieve the bookie driver for scheme.

Parameters:

scheme - the scheme for the metadata bookie driver

Returns:

the metadata bookie driver

Throws:

NullPointerException - when scheme is null

getBookieDriver

public static MetadataBookieDriver getBookieDriver(URI uri)

Retrieve the bookie driver for uri.

Parameters:

uri - the metadata service uri

Returns:

the metadata bookie driver for uri

Throws:

NullPointerException - if the metadata service uri is null or doesn't have scheme or there is no namespace driver registered for the scheme

IllegalArgumentException - if the metadata service uri scheme is illegal

runFunctionWithMetadataClientDriver

public static <T> T runFunctionWithMetadataClientDriver(ClientConfiguration conf,
 Function<MetadataClientDriver,T> function,
 ScheduledExecutorService executorService)
                                                 throws MetadataException,
ExecutionException

Process the provided function with metadata client driver resolved from the metadata service uri returned by AbstractConfiguration.getMetadataServiceUri().

Parameters:

conf - client configuration

function - function to apply with metadata client driver.

executorService - executor service used by the metadata client driver.

Throws:

MetadataException - when failed to access metadata store

ExecutionException - exception thrown when processing function.

runFunctionWithMetadataBookieDriver

public static <T> T runFunctionWithMetadataBookieDriver(ServerConfiguration conf,
 Function<MetadataBookieDriver,T> function)
                                                 throws MetadataException,
ExecutionException

Process the provided function with metadata bookie driver resolved from the metadata service uri returned by AbstractConfiguration.getMetadataServiceUri().

Parameters:

conf - server configuration

function - function to apply with metadata bookie driver.

Throws:

MetadataException - when failed to access metadata store

ExecutionException - exception thrown when processing function.

runFunctionWithRegistrationManager

public static <T> T runFunctionWithRegistrationManager(ServerConfiguration conf,
 Function<RegistrationManager,T> function)
                                                throws MetadataException,
ExecutionException

Process the provided function with registration manager resolved from the metadata service uri returned by AbstractConfiguration.getMetadataServiceUri().

Parameters:

conf - server configuration

function - function to apply with registration manager.

Throws:

MetadataException - when failed to access metadata store

ExecutionException - exception thrown when processing consumer.

runFunctionWithLedgerManagerFactory

public static <T> T runFunctionWithLedgerManagerFactory(ServerConfiguration conf,
 Function<LedgerManagerFactory,T> function)
                                                 throws MetadataException,
ExecutionException

Process the provided function with ledger manager factory resolved from the metadata service uri returned by AbstractConfiguration.getMetadataServiceUri().

Parameters:

conf - server configuration

function - function to apply with ledger manager factory.

Throws:

MetadataException - when failed to access metadata store

ExecutionException - exception thrown when processing consumer.

getClientDrivers

static ConcurrentMap<String,MetadataDrivers.MetadataClientDriverInfo> getClientDrivers()

getBookieDrivers

static ConcurrentMap<String,MetadataDrivers.MetadataBookieDriverInfo> getBookieDrivers()