Package org.apache.bookkeeper.meta.zk

Class ZKMetadataDriverBase

java.lang.Object

org.apache.bookkeeper.meta.zk.ZKMetadataDriverBase

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

ZKMetadataBookieDriver, ZKMetadataClientDriver

public class ZKMetadataDriverBase
extends Object
implements AutoCloseable

This is a mixin class for supporting zookeeper based metadata driver.

Field Summary

Fields

Modifier and Type	Field	Description
protected List<org.apache.zookeeper.data.ACL>	acls
protected AbstractConfiguration<?>	conf
(package private) String	disableHealthCheckPath
protected LayoutManager	layoutManager
protected String	ledgersRootPath
protected LedgerManagerFactory	lmFactory
protected boolean	metadataServiceAvailable
protected boolean	ownZKHandle
protected static final String	SCHEME
protected StatsLogger	statsLogger
protected org.apache.zookeeper.ZooKeeper	zk

Constructor Summary

Constructors

Constructor	Description
ZKMetadataDriverBase()

Method Summary

Modifier and Type	Method	Description
void	close()
CompletableFuture<Void>	disableHealthCheck()
CompletableFuture<Void>	enableHealthCheck()
LayoutManager	getLayoutManager()
LedgerManagerFactory	getLedgerManagerFactory()
String	getScheme()
org.apache.zookeeper.ZooKeeper	getZk()
static String	getZKServersFromServiceUri(URI uri)
protected void	initialize(AbstractConfiguration<?> conf, StatsLogger statsLogger, RetryPolicy zkRetryPolicy, Optional<Object> optionalCtx)
CompletableFuture<Boolean>	isHealthCheckEnabled()
static Class<? extends LedgerManagerFactory>	resolveLedgerManagerFactory(URI metadataServiceUri)
static String	resolveZkLedgersRootPath(AbstractConfiguration<?> conf)
static String	resolveZkServers(AbstractConfiguration<?> conf)
void	setZk(org.apache.zookeeper.ZooKeeper zk)

Methods inherited from class java.lang.Object

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

Field Details

SCHEME

protected static final String SCHEME

See Also:

• Constant Field Values

metadataServiceAvailable

protected volatile boolean metadataServiceAvailable

conf

protected AbstractConfiguration<?> conf

statsLogger

protected StatsLogger statsLogger

acls

protected List<org.apache.zookeeper.data.ACL> acls

zk

protected org.apache.zookeeper.ZooKeeper zk

ownZKHandle

protected boolean ownZKHandle

disableHealthCheckPath

String disableHealthCheckPath

ledgersRootPath

protected String ledgersRootPath

layoutManager

protected LayoutManager layoutManager

lmFactory

protected LedgerManagerFactory lmFactory

Constructor Details

ZKMetadataDriverBase

public ZKMetadataDriverBase()

Method Details

getZKServersFromServiceUri

public static String getZKServersFromServiceUri(URI uri)

resolveZkServers

public static String resolveZkServers(AbstractConfiguration<?> conf)

resolveZkLedgersRootPath

public static String resolveZkLedgersRootPath(AbstractConfiguration<?> conf)

resolveLedgerManagerFactory

public static Class<? extends LedgerManagerFactory> resolveLedgerManagerFactory(URI metadataServiceUri)

getScheme

public String getScheme()

initialize

protected void initialize(AbstractConfiguration<?> conf,
 StatsLogger statsLogger,
 RetryPolicy zkRetryPolicy,
 Optional<Object> optionalCtx)
                   throws MetadataException

Throws:

MetadataException

getLayoutManager

public LayoutManager getLayoutManager()

getLedgerManagerFactory

public LedgerManagerFactory getLedgerManagerFactory()
                                             throws MetadataException

Throws:

MetadataException

disableHealthCheck

public CompletableFuture<Void> disableHealthCheck()

enableHealthCheck

public CompletableFuture<Void> enableHealthCheck()

isHealthCheckEnabled

public CompletableFuture<Boolean> isHealthCheckEnabled()

close

public void close()

Specified by:

close in interface AutoCloseable

getZk

public org.apache.zookeeper.ZooKeeper getZk()

setZk

public void setZk(org.apache.zookeeper.ZooKeeper zk)