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
This is a mixin class for supporting zookeeper based metadata driver.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected List<org.apache.zookeeper.data.ACL>protected AbstractConfiguration<?>(package private) Stringprotected LayoutManagerprotected Stringprotected LedgerManagerFactoryprotected booleanprotected booleanprotected static final Stringprotected StatsLoggerprotected org.apache.zookeeper.ZooKeeper -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()org.apache.zookeeper.ZooKeepergetZk()static Stringprotected voidinitialize(AbstractConfiguration<?> conf, StatsLogger statsLogger, RetryPolicy zkRetryPolicy, Optional<Object> optionalCtx) static Class<? extends LedgerManagerFactory>resolveLedgerManagerFactory(URI metadataServiceUri) static Stringstatic StringresolveZkServers(AbstractConfiguration<?> conf) voidsetZk(org.apache.zookeeper.ZooKeeper zk)
-
Field Details
-
SCHEME
- See Also:
-
metadataServiceAvailable
protected volatile boolean metadataServiceAvailable -
conf
-
statsLogger
-
acls
-
zk
protected org.apache.zookeeper.ZooKeeper zk -
ownZKHandle
protected boolean ownZKHandle -
disableHealthCheckPath
String disableHealthCheckPath -
ledgersRootPath
-
layoutManager
-
lmFactory
-
-
Constructor Details
-
ZKMetadataDriverBase
public ZKMetadataDriverBase()
-
-
Method Details
-
getZKServersFromServiceUri
-
resolveZkServers
-
resolveZkLedgersRootPath
-
resolveLedgerManagerFactory
public static Class<? extends LedgerManagerFactory> resolveLedgerManagerFactory(URI metadataServiceUri) -
getScheme
-
initialize
protected void initialize(AbstractConfiguration<?> conf, StatsLogger statsLogger, RetryPolicy zkRetryPolicy, Optional<Object> optionalCtx) throws MetadataException - Throws:
MetadataException
-
getLayoutManager
-
getLedgerManagerFactory
- Throws:
MetadataException
-
disableHealthCheck
-
enableHealthCheck
-
isHealthCheckEnabled
-
close
public void close()- Specified by:
closein interfaceAutoCloseable
-
getZk
public org.apache.zookeeper.ZooKeeper getZk() -
setZk
public void setZk(org.apache.zookeeper.ZooKeeper zk)
-