Uses of Interface
org.apache.bookkeeper.proto.BookieAddressResolver
-
Packages that use BookieAddressResolver Package Description org.apache.bookkeeper.bookie Provides a Bookie server that stores entries for clients.org.apache.bookkeeper.client BookKeeper Client.org.apache.bookkeeper.net Network-related classes.org.apache.bookkeeper.proto Classes related to the Bookkeeper protocol.org.apache.bookkeeper.tools.cli.helpers This classes provides some helper mixins for easily to add commands to bookie shell. -
-
Uses of BookieAddressResolver in org.apache.bookkeeper.bookie
Methods in org.apache.bookkeeper.bookie with parameters of type BookieAddressResolver Modifier and Type Method Description EnsemblePlacementPolicy
LocalBookieEnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer hashedWheelTimer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
-
Uses of BookieAddressResolver in org.apache.bookkeeper.client
Classes in org.apache.bookkeeper.client that implement BookieAddressResolver Modifier and Type Class Description class
BookieAddressResolverDisabled
Resolve legacy style BookieIDs to Network addresses.class
DefaultBookieAddressResolver
Resolve BookieIDs to Network addresses.Fields in org.apache.bookkeeper.client declared as BookieAddressResolver Modifier and Type Field Description protected BookieAddressResolver
TopologyAwareEnsemblePlacementPolicy. bookieAddressResolver
Methods in org.apache.bookkeeper.client that return BookieAddressResolver Modifier and Type Method Description BookieAddressResolver
BookieWatcher. getBookieAddressResolver()
BookieAddressResolver
BookieWatcherImpl. getBookieAddressResolver()
BookieAddressResolver
BookKeeper. getBookieAddressResolver()
BookieAddressResolver
BookKeeperAdmin. getBookieAddressResolver()
Methods in org.apache.bookkeeper.client with parameters of type BookieAddressResolver Modifier and Type Method Description EnsemblePlacementPolicy
DefaultEnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer hashedWheelTimer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
EnsemblePlacementPolicy
EnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer hashedWheelTimer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
Initialize the policy.protected RackawareEnsemblePlacementPolicy
RackawareEnsemblePlacementPolicy. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, boolean useHostnameResolveLocalNodePlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
protected RackawareEnsemblePlacementPolicy
RackawareEnsemblePlacementPolicy. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
protected RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, boolean useHostnameResolveLocalNodePlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
Initialize the policy.protected RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
Initialize the policy.RegionAwareEnsemblePlacementPolicy
RegionAwareEnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
EnsemblePlacementPolicy
ZoneawareEnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
EnsemblePlacementPolicy
ZoneawareEnsemblePlacementPolicyImpl. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
protected EnsemblePlacementPolicy
BookKeeper. initializeEnsemblePlacementPolicy(ClientConfiguration conf, DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
void
TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator. setBookieAddressResolver(BookieAddressResolver bookieAddressResolver)
Constructors in org.apache.bookkeeper.client with parameters of type BookieAddressResolver Constructor Description BookieWatcherImpl(ClientConfiguration conf, EnsemblePlacementPolicy placementPolicy, RegistrationClient registrationClient, BookieAddressResolver bookieAddressResolver, StatsLogger statsLogger)
-
Uses of BookieAddressResolver in org.apache.bookkeeper.net
Fields in org.apache.bookkeeper.net declared as BookieAddressResolver Modifier and Type Field Description static BookieAddressResolver
BookieSocketAddress. LEGACY_BOOKIEID_RESOLVER
Simple converter from legacy BookieId to a real network address.Methods in org.apache.bookkeeper.net that return BookieAddressResolver Modifier and Type Method Description BookieAddressResolver
AbstractDNSToSwitchMapping. getBookieAddressResolver()
Methods in org.apache.bookkeeper.net with parameters of type BookieAddressResolver Modifier and Type Method Description void
AbstractDNSToSwitchMapping. setBookieAddressResolver(BookieAddressResolver bookieAddressResolver)
default void
DNSToSwitchMapping. setBookieAddressResolver(BookieAddressResolver bookieAddressResolver)
Receives the current BookieAddressResolver. -
Uses of BookieAddressResolver in org.apache.bookkeeper.proto
Fields in org.apache.bookkeeper.proto declared as BookieAddressResolver Modifier and Type Field Description (package private) BookieAddressResolver
PerChannelBookieClient. bookieAddressResolver
Constructors in org.apache.bookkeeper.proto with parameters of type BookieAddressResolver Constructor Description BookieClientImpl(ClientConfiguration conf, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.buffer.ByteBufAllocator allocator, OrderedExecutor executor, java.util.concurrent.ScheduledExecutorService scheduler, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
PerChannelBookieClient(OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, BookieId bookieId, ClientAuthProvider.Factory authProviderFactory, com.google.protobuf.ExtensionRegistry extRegistry, BookieAddressResolver bookieAddressResolver)
PerChannelBookieClient(OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, BookieId addr, BookieAddressResolver bookieAddressResolver)
PerChannelBookieClient(ClientConfiguration conf, OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.buffer.ByteBufAllocator allocator, BookieId bookieId, StatsLogger parentStatsLogger, ClientAuthProvider.Factory authProviderFactory, com.google.protobuf.ExtensionRegistry extRegistry, PerChannelBookieClientPool pcbcPool, SecurityHandlerFactory shFactory, BookieAddressResolver bookieAddressResolver)
PerChannelBookieClient(ClientConfiguration conf, OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, BookieId bookieId, StatsLogger parentStatsLogger, ClientAuthProvider.Factory authProviderFactory, com.google.protobuf.ExtensionRegistry extRegistry, PerChannelBookieClientPool pcbcPool, BookieAddressResolver bookieAddressResolver)
-
Uses of BookieAddressResolver in org.apache.bookkeeper.tools.cli.helpers
Methods in org.apache.bookkeeper.tools.cli.helpers with parameters of type BookieAddressResolver Modifier and Type Method Description static java.lang.String
CommandHelpers. getBookieSocketAddrStringRepresentation(BookieId bookieId, BookieAddressResolver bookieAddressResolver)
-