| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| org.apache.bookkeeper.client.api |
BookKeeper Client Public API.
|
| org.apache.bookkeeper.client.impl |
BookKeeper Client implementation package.
|
| org.apache.bookkeeper.feature |
A feature-flag system
that is used to proportionally control what features are enabled for the system.
|
| Modifier and Type | Field and Description |
|---|---|
protected FeatureProvider |
RegionAwareEnsemblePlacementPolicy.featureProvider |
(package private) FeatureProvider |
BookKeeper.featureProvider |
(package private) FeatureProvider |
BookKeeper.Builder.featureProvider |
| Modifier and Type | Method and Description |
|---|---|
BookKeeper.Builder |
BookKeeper.Builder.featureProvider(FeatureProvider featureProvider)
Feature Provider.
|
(package private) static ClientInternalConf |
ClientInternalConf.fromConfigAndFeatureProvider(ClientConfiguration conf,
FeatureProvider featureProvider) |
RegionAwareEnsemblePlacementPolicy |
RegionAwareEnsemblePlacementPolicy.initialize(ClientConfiguration conf,
java.util.Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver,
io.netty.util.HashedWheelTimer timer,
FeatureProvider featureProvider,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver) |
EnsemblePlacementPolicy |
ZoneawareEnsemblePlacementPolicy.initialize(ClientConfiguration conf,
java.util.Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver,
io.netty.util.HashedWheelTimer timer,
FeatureProvider featureProvider,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver) |
EnsemblePlacementPolicy |
ZoneawareEnsemblePlacementPolicyImpl.initialize(ClientConfiguration conf,
java.util.Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver,
io.netty.util.HashedWheelTimer timer,
FeatureProvider featureProvider,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver) |
EnsemblePlacementPolicy |
DefaultEnsemblePlacementPolicy.initialize(ClientConfiguration conf,
java.util.Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver,
io.netty.util.HashedWheelTimer hashedWheelTimer,
FeatureProvider featureProvider,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver) |
EnsemblePlacementPolicy |
EnsemblePlacementPolicy.initialize(ClientConfiguration conf,
java.util.Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver,
io.netty.util.HashedWheelTimer hashedWheelTimer,
FeatureProvider featureProvider,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver)
Initialize the policy.
|
RackawareEnsemblePlacementPolicyImpl |
RackawareEnsemblePlacementPolicyImpl.initialize(ClientConfiguration conf,
java.util.Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver,
io.netty.util.HashedWheelTimer timer,
FeatureProvider featureProvider,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver) |
| Constructor and Description |
|---|
BookKeeper(ClientConfiguration conf,
org.apache.zookeeper.ZooKeeper zkc,
io.netty.channel.EventLoopGroup eventLoopGroup,
io.netty.buffer.ByteBufAllocator byteBufAllocator,
org.apache.bookkeeper.stats.StatsLogger rootStatsLogger,
org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver,
io.netty.util.HashedWheelTimer requestTimer,
FeatureProvider featureProvider)
Constructor for use with the builder.
|
| Modifier and Type | Method and Description |
|---|---|
BookKeeperBuilder |
BookKeeperBuilder.featureProvider(FeatureProvider featureProvider)
Configure the bookkeeper client to use a provided
FeatureProvider. |
| Modifier and Type | Method and Description |
|---|---|
BookKeeperBuilder |
BookKeeperBuilderImpl.featureProvider(FeatureProvider featureProvider) |
| Modifier and Type | Class and Description |
|---|---|
class |
CacheableFeatureProvider<T extends Feature>
Cacheable Feature Provider.
|
class |
SettableFeatureProvider
A provider will provide settable features.
|
| Modifier and Type | Field and Description |
|---|---|
static FeatureProvider |
SettableFeatureProvider.DISABLE_ALL |
| Modifier and Type | Field and Description |
|---|---|
protected java.util.concurrent.ConcurrentMap<java.lang.String,FeatureProvider> |
CacheableFeatureProvider.scopes |
| Modifier and Type | Method and Description |
|---|---|
protected FeatureProvider |
SettableFeatureProvider.makeProvider(java.lang.String fullScopeName) |
protected abstract FeatureProvider |
CacheableFeatureProvider.makeProvider(java.lang.String fullScopeName) |
FeatureProvider |
FeatureProvider.scope(java.lang.String name)
Provide the feature provider under scope name.
|
FeatureProvider |
CacheableFeatureProvider.scope(java.lang.String name) |
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.