Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 76336200D0A for ; Wed, 4 Oct 2017 09:35:42 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 743941609E2; Wed, 4 Oct 2017 07:35:42 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id DA50D1609D6 for ; Wed, 4 Oct 2017 09:35:35 +0200 (CEST) Received: (qmail 47223 invoked by uid 500); 4 Oct 2017 07:35:34 -0000 Mailing-List: contact commits-help@bookkeeper.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: bookkeeper-dev@bookkeeper.apache.org Delivered-To: mailing list commits@bookkeeper.apache.org Received: (qmail 47214 invoked by uid 99); 4 Oct 2017 07:35:34 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 04 Oct 2017 07:35:34 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id A20038196A; Wed, 4 Oct 2017 07:35:31 +0000 (UTC) Date: Wed, 04 Oct 2017 07:35:31 +0000 To: "commits@bookkeeper.apache.org" Subject: [bookkeeper] branch asf-site updated: Updated site at revision 758cdeb MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <150710253108.31136.12663102339170319417@gitbox.apache.org> From: git-site-role@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: bookkeeper X-Git-Refname: refs/heads/asf-site X-Git-Reftype: branch X-Git-Oldrev: 9329b845adf12feab059f1729ec58cfd7469eca0 X-Git-Newrev: 0ce02e5b6a4bb32173a6d5a1000786c55ed83a62 X-Git-Rev: 0ce02e5b6a4bb32173a6d5a1000786c55ed83a62 X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated archived-at: Wed, 04 Oct 2017 07:35:42 -0000 This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/bookkeeper.git The following commit(s) were added to refs/heads/asf-site by this push: new 0ce02e5 Updated site at revision 758cdeb 0ce02e5 is described below commit 0ce02e5b6a4bb32173a6d5a1000786c55ed83a62 Author: jenkins AuthorDate: Wed Oct 4 07:35:28 2017 +0000 Updated site at revision 758cdeb --- .../class-use/AsyncCallback.AddCallback.html | 24 +- .../class-use/AsyncCallback.CloseCallback.html | 10 +- .../BKException.BKNotEnoughBookiesException.html | 28 +- .../bookkeeper/client/class-use/BKException.html | 48 +-- .../bookkeeper/client/class-use/BookKeeper.html | 8 +- .../class-use/BookieInfoReader.BookieInfo.html | 12 +- .../client/class-use/BookiesListener.html | 14 +- .../class-use/DigestManager.RecoveryData.html | 4 +- .../class-use/DistributionSchedule.AckSet.html | 4 +- .../DistributionSchedule.QuorumCoverageSet.html | 4 +- .../client/class-use/EnsemblePlacementPolicy.html | 4 +- ...ologyAwareEnsemblePlacementPolicy.Ensemble.html | 8 +- ...logyAwareEnsemblePlacementPolicy.Predicate.html | 8 +- .../bookkeeper/client/class-use/LedgerEntry.html | 12 +- .../bookkeeper/client/class-use/LedgerHandle.html | 76 ++-- .../client/class-use/LedgerMetadata.html | 14 +- ...dLastConfirmedOp.LastConfirmedDataCallback.html | 4 +- ...ogyAwareEnsemblePlacementPolicy.BookieNode.html | 20 +- .../org/apache/bookkeeper/client/package-tree.html | 2 +- .../conf/class-use/ClientConfiguration.html | 12 +- .../feature/class-use/FeatureProvider.html | 22 +- .../apache/bookkeeper/stats/class-use/Counter.html | 6 +- .../apache/bookkeeper/stats/class-use/Gauge.html | 24 +- .../bookkeeper/stats/class-use/OpStatsData.html | 4 +- .../bookkeeper/stats/class-use/OpStatsLogger.html | 6 +- .../bookkeeper/stats/class-use/StatsLogger.html | 66 ++-- content/docs/4.5.0/api/javadoc/overview-tree.html | 2 +- .../docs/latest/api/javadoc/allclasses-frame.html | 10 +- .../latest/api/javadoc/allclasses-noframe.html | 10 +- content/docs/latest/api/javadoc/index-all.html | 66 ++-- .../class-use/AsyncCallback.AddCallback.html | 24 +- .../class-use/AsyncCallback.CloseCallback.html | 10 +- .../BKException.BKNotEnoughBookiesException.html | 28 +- .../bookkeeper/client/class-use/BKException.html | 48 +-- .../bookkeeper/client/class-use/BookKeeper.html | 8 +- .../class-use/BookieInfoReader.BookieInfo.html | 12 +- .../client/class-use/BookiesListener.html | 14 +- .../class-use/DigestManager.RecoveryData.html | 4 +- .../class-use/DistributionSchedule.AckSet.html | 4 +- .../DistributionSchedule.QuorumCoverageSet.html | 4 +- .../client/class-use/EnsemblePlacementPolicy.html | 4 +- ...ologyAwareEnsemblePlacementPolicy.Ensemble.html | 8 +- ...logyAwareEnsemblePlacementPolicy.Predicate.html | 8 +- .../bookkeeper/client/class-use/LedgerEntry.html | 12 +- .../bookkeeper/client/class-use/LedgerHandle.html | 76 ++-- .../client/class-use/LedgerMetadata.html | 14 +- ...dLastConfirmedOp.LastConfirmedDataCallback.html | 4 +- ...ogyAwareEnsemblePlacementPolicy.BookieNode.html | 20 +- .../org/apache/bookkeeper/client/package-tree.html | 2 +- .../conf/class-use/ClientConfiguration.html | 12 +- .../feature/class-use/FeatureProvider.html | 22 +- .../org/apache/bookkeeper/stats/Counter.html | 2 +- .../org/apache/bookkeeper/stats/OpStatsLogger.html | 6 +- .../javadoc/org/apache/bookkeeper/stats/Stats.html | 4 +- .../org/apache/bookkeeper/stats/StatsLogger.html | 2 +- .../org/apache/bookkeeper/stats/StatsProvider.html | 2 +- .../apache/bookkeeper/stats/class-use/Counter.html | 51 ++- .../apache/bookkeeper/stats/class-use/Gauge.html | 48 ++- .../bookkeeper/stats/class-use/OpStatsData.html | 36 +- .../bookkeeper/stats/class-use/OpStatsLogger.html | 51 ++- .../bookkeeper/stats/class-use/StatsLogger.html | 134 ++++--- .../bookkeeper/stats/class-use/StatsProvider.html | 36 +- .../org/apache/bookkeeper/stats/package-frame.html | 5 - .../apache/bookkeeper/stats/package-summary.html | 34 +- .../org/apache/bookkeeper/stats/package-tree.html | 9 +- .../org/apache/bookkeeper/stats/package-use.html | 53 ++- .../stats/prometheus/PrometheusCounter.html | 372 +++++++++++++++++++ .../prometheus/PrometheusMetricsProvider.html | 334 +++++++++++++++++ .../stats/prometheus/PrometheusOpStatsLogger.html | 402 ++++++++++++++++++++ .../stats/prometheus/PrometheusStatsLogger.html | 413 +++++++++++++++++++++ .../{Stats.html => prometheus/PrometheusUtil.html} | 167 +++------ .../prometheus/class-use/PrometheusCounter.html | 125 +++++++ .../class-use/PrometheusMetricsProvider.html | 125 +++++++ .../class-use/PrometheusOpStatsLogger.html | 125 +++++++ .../class-use/PrometheusStatsLogger.html | 125 +++++++ .../stats/prometheus/class-use/PrometheusUtil.html | 125 +++++++ .../bookkeeper/stats/prometheus/package-frame.html | 24 ++ .../stats/prometheus/package-summary.html | 178 +++++++++ .../bookkeeper/stats/prometheus/package-tree.html | 142 +++++++ .../bookkeeper/stats/prometheus/package-use.html | 125 +++++++ .../stats/twitter/finagle/package-summary.html | 4 +- .../stats/twitter/finagle/package-tree.html | 4 +- .../docs/latest/api/javadoc/overview-frame.html | 1 + .../docs/latest/api/javadoc/overview-summary.html | 17 + content/docs/latest/api/javadoc/overview-tree.html | 13 +- content/docs/latest/api/javadoc/package-list | 1 + 86 files changed, 3447 insertions(+), 718 deletions(-) diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.AddCallback.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.AddCallback.html index 0bd0572..879beff 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.AddCallback.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.AddCallback.html @@ -138,27 +138,19 @@ void -ReadOnlyLedgerHandle.asyncAddEntry(byte[] data, - AsyncCallback.AddCallback cb, - Object ctx)  - - -void LedgerHandle.asyncAddEntry(byte[] data, AsyncCallback.AddCallback cb, Object ctx)
Add entry asynchronously to an open ledger.
- + void -ReadOnlyLedgerHandle.asyncAddEntry(byte[] data, - int offset, - int length, +ReadOnlyLedgerHandle.asyncAddEntry(byte[] data, AsyncCallback.AddCallback cb, Object ctx)  - + void LedgerHandle.asyncAddEntry(byte[] data, int offset, @@ -168,7 +160,7 @@
Add entry asynchronously to an open ledger, using an offset and range.
- + void LedgerHandleAdv.asyncAddEntry(byte[] data, int offset, @@ -178,6 +170,14 @@
LedgerHandleAdv will not allow addEntry without providing an entryId
+ +void +ReadOnlyLedgerHandle.asyncAddEntry(byte[] data, + int offset, + int length, + AsyncCallback.AddCallback cb, + Object ctx)  + void LedgerHandle.asyncAddEntry(io.netty.buffer.ByteBuf data, diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.CloseCallback.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.CloseCallback.html index abde95b..738230f 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.CloseCallback.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.CloseCallback.html @@ -123,16 +123,16 @@ void -ReadOnlyLedgerHandle.asyncClose(AsyncCallback.CloseCallback cb, - Object ctx)  - - -void LedgerHandle.asyncClose(AsyncCallback.CloseCallback cb, Object ctx)
Asynchronous close, any adds in flight will return errors.
+ +void +ReadOnlyLedgerHandle.asyncClose(AsyncCallback.CloseCallback cb, + Object ctx)  + (package private) void LedgerHandle.asyncCloseInternal(AsyncCallback.CloseCallback cb, diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.BKNotEnoughBookiesException.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.BKNotEnoughBookiesException.html index d407b03..9a76bc7 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.BKNotEnoughBookiesException.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.BKNotEnoughBookiesException.html @@ -115,7 +115,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -123,23 +123,23 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -DefaultEnsemblePlacementPolicy.newEnsemble(int ensembleSize, - int quorumSize, +RegionAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, + int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies)  ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, - int writeQuorumSize, +DefaultEnsemblePlacementPolicy.newEnsemble(int ensembleSize, + int quorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies)  ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RegionAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -168,7 +168,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -177,7 +177,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -203,7 +203,7 @@ org.apache.bookkeeper.net.BookieSocketAddress -RackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -213,7 +213,7 @@ org.apache.bookkeeper.net.BookieSocketAddress -DefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize, +RegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -223,7 +223,7 @@ org.apache.bookkeeper.net.BookieSocketAddress -RackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, +DefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -233,7 +233,7 @@ org.apache.bookkeeper.net.BookieSocketAddress -RegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, +RackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -289,14 +289,14 @@ TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.html index 490cece..76ad3fd 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.html @@ -258,21 +258,15 @@ long -ReadOnlyLedgerHandle.addEntry(byte[] data)  - - -long LedgerHandle.addEntry(byte[] data)
Add entry synchronously to an open ledger.
- + long -ReadOnlyLedgerHandle.addEntry(byte[] data, - int offset, - int length)  +ReadOnlyLedgerHandle.addEntry(byte[] data)  - + long LedgerHandle.addEntry(byte[] data, int offset, @@ -280,6 +274,12 @@
Add entry synchronously to an open ledger.
+ +long +ReadOnlyLedgerHandle.addEntry(byte[] data, + int offset, + int length)  + long LedgerHandle.addEntry(long entryId, @@ -325,7 +325,9 @@ void -ReadOnlyLedgerHandle.close()  +BookKeeper.close() +
Shuts down client.
+ void @@ -341,9 +343,7 @@ void -BookKeeper.close() -
Shuts down client.
- +ReadOnlyLedgerHandle.close()  LedgerHandle @@ -436,15 +436,15 @@ -(package private) Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> -BookieInfoReader.getBookieInfo()  - - Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> BookKeeper.getBookieInfo()
Retrieves BookieInfo from all the bookies in the cluster.
+ +(package private) Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> +BookieInfoReader.getBookieInfo()  + Collection<org.apache.bookkeeper.net.BookieSocketAddress> BookieWatcher.getBookies()  @@ -457,25 +457,25 @@ +(package private) void +BookieWatcher.notifyBookiesChanged(BookiesListener listener)  + + void BookKeeperAdmin.notifyBookiesChanged(BookiesListener listener)
Notify when the available list of bookies changes.
- + (package private) void -BookieWatcher.notifyBookiesChanged(BookiesListener listener)  +BookieWatcher.notifyReadOnlyBookiesChanged(BookiesListener listener)  - + void BookKeeperAdmin.notifyReadOnlyBookiesChanged(BookiesListener listener)
Notify when the available list of read only bookies changes.
- -(package private) void -BookieWatcher.notifyReadOnlyBookiesChanged(BookiesListener listener)  - LedgerHandle BookKeeperAdmin.openLedger(long lId) diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookKeeper.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookKeeper.html index 56e172b..ba13363 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookKeeper.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookKeeper.html @@ -106,15 +106,15 @@ (package private) BookKeeper -LedgerCreateOp.bk  +BookieWatcher.bk  (package private) BookKeeper -LedgerHandle.bk  +LedgerCreateOp.bk  (package private) BookKeeper -LedgerDeleteOp.bk  +LedgerHandle.bk  (package private) BookKeeper @@ -122,7 +122,7 @@ (package private) BookKeeper -BookieWatcher.bk  +LedgerDeleteOp.bk  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookieInfoReader.BookieInfo.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookieInfoReader.BookieInfo.html index 833cf9d..02f05c5 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookieInfoReader.BookieInfo.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookieInfoReader.BookieInfo.html @@ -105,15 +105,15 @@ -(package private) Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> -BookieInfoReader.getBookieInfo()  - - Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> BookKeeper.getBookieInfo()
Retrieves BookieInfo from all the bookies in the cluster.
+ +(package private) Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> +BookieInfoReader.getBookieInfo()  + @@ -125,11 +125,11 @@ - - diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookiesListener.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookiesListener.html index 87c63a8..cafa1fe 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookiesListener.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/BookiesListener.html @@ -105,25 +105,25 @@ + + + + - + - + - + - - - -
voidDefaultEnsemblePlacementPolicy.updateBookieInfo(Map<org.apache.bookkeeper.net.BookieSocketAddress,RackawareEnsemblePlacementPolicyImpl.updateBookieInfo(Map<org.apache.bookkeeper.net.BookieSocketAddress, voidRackawareEnsemblePlacementPolicyImpl.updateBookieInfo(Map<org.apache.bookkeeper.net.BookieSocketAddress,DefaultEnsemblePlacementPolicy.updateBookieInfo(Map<org.apache.bookkeeper.net.BookieSocketAddress, default void
(package private) voidBookieWatcher.notifyBookiesChanged(BookiesListener listener) 
void BookKeeperAdmin.notifyBookiesChanged(BookiesListener listener)
Notify when the available list of bookies changes.
(package private) voidBookieWatcher.notifyBookiesChanged(BookiesListener listener) BookieWatcher.notifyReadOnlyBookiesChanged(BookiesListener listener) 
void BookKeeperAdmin.notifyReadOnlyBookiesChanged(BookiesListener listener)
Notify when the available list of read only bookies changes.
(package private) voidBookieWatcher.notifyReadOnlyBookiesChanged(BookiesListener listener) 
diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DigestManager.RecoveryData.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DigestManager.RecoveryData.html index 438fc15..beb76a8 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DigestManager.RecoveryData.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DigestManager.RecoveryData.html @@ -106,11 +106,11 @@ (package private) DigestManager.RecoveryData -ReadLastConfirmedOp.maxRecoveredData  +TryReadLastConfirmedOp.maxRecoveredData  (package private) DigestManager.RecoveryData -TryReadLastConfirmedOp.maxRecoveredData  +ReadLastConfirmedOp.maxRecoveredData  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.AckSet.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.AckSet.html index fecff66..3fb9511 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.AckSet.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.AckSet.html @@ -106,11 +106,11 @@ (package private) DistributionSchedule.AckSet -PendingAddOp.ackSet  +PendingWriteLacOp.ackSet  (package private) DistributionSchedule.AckSet -PendingWriteLacOp.ackSet  +PendingAddOp.ackSet  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.QuorumCoverageSet.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.QuorumCoverageSet.html index 253b66d..120d07d 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.QuorumCoverageSet.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.QuorumCoverageSet.html @@ -106,11 +106,11 @@ (package private) DistributionSchedule.QuorumCoverageSet -PendingReadLacOp.coverageSet  +ReadLastConfirmedOp.coverageSet  (package private) DistributionSchedule.QuorumCoverageSet -ReadLastConfirmedOp.coverageSet  +PendingReadLacOp.coverageSet  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/EnsemblePlacementPolicy.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/EnsemblePlacementPolicy.html index c97b41e..4f7d52f 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/EnsemblePlacementPolicy.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/EnsemblePlacementPolicy.html @@ -162,11 +162,11 @@ (package private) EnsemblePlacementPolicy -BookKeeper.placementPolicy  +BookieWatcher.placementPolicy  (package private) EnsemblePlacementPolicy -BookieWatcher.placementPolicy  +BookKeeper.placementPolicy  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Ensemble.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Ensemble.html index 811bc1d..eeba25f 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Ensemble.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Ensemble.html @@ -165,7 +165,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -174,7 +174,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -217,14 +217,14 @@ TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Predicate.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Predicate.html index c3721cc..4145f1a 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Predicate.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Predicate.html @@ -150,7 +150,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -159,7 +159,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -202,14 +202,14 @@ TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerEntry.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerEntry.html index 90bec26..ee14960 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerEntry.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerEntry.html @@ -169,11 +169,11 @@ LedgerEntry -PendingReadOp.nextElement()  +ListenerBasedPendingReadOp.nextElement()  LedgerEntry -ListenerBasedPendingReadOp.nextElement()  +PendingReadOp.nextElement()  @@ -259,20 +259,20 @@ void -LedgerHandle.SyncReadCallback.readComplete(int rc, +AsyncCallback.ReadCallback.readComplete(int rc, LedgerHandle lh, Enumeration<LedgerEntry> seq, Object ctx) -
Implementation of callback interface for synchronous read method.
+
Callback declaration
void -AsyncCallback.ReadCallback.readComplete(int rc, +LedgerHandle.SyncReadCallback.readComplete(int rc, LedgerHandle lh, Enumeration<LedgerEntry> seq, Object ctx) -
Callback declaration
+
Implementation of callback interface for synchronous read method.
diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerHandle.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerHandle.html index e25e6c2..fb1ca75 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerHandle.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerHandle.html @@ -132,51 +132,51 @@ (package private) LedgerHandle -SyncCounter.lh  +PendingWriteLacOp.lh  (package private) LedgerHandle -LedgerCreateOp.lh  +TryReadLastConfirmedOp.lh  (package private) LedgerHandle -PendingReadOp.lh  +PendingAddOp.lh  (package private) LedgerHandle -PendingReadLacOp.lh  +ReadLastConfirmedOp.lh  (package private) LedgerHandle -ReadLastConfirmedOp.lh  +ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl.lh  (package private) LedgerHandle -LedgerOpenOp.lh  +LedgerFragmentReplicator.SingleFragmentCallback.lh  (package private) LedgerHandle -ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl.lh  +LedgerCreateOp.lh  (package private) LedgerHandle -TryReadLastConfirmedOp.lh  +SyncCounter.lh  (package private) LedgerHandle -PendingAddOp.lh  +LedgerRecoveryOp.lh  (package private) LedgerHandle -LedgerRecoveryOp.lh  +LedgerOpenOp.lh  (package private) LedgerHandle -PendingWriteLacOp.lh  +PendingReadOp.lh  (package private) LedgerHandle -LedgerFragmentReplicator.SingleFragmentCallback.lh  +PendingReadLacOp.lh  @@ -300,43 +300,43 @@ void -LedgerHandle.SyncAddCallback.addComplete(int rc, +AsyncCallback.AddCallback.addComplete(int rc, LedgerHandle lh, - long entry, + long entryId, Object ctx) -
Implementation of callback interface for synchronous read method.
+
Callback declaration
void -LedgerRecoveryOp.addComplete(int rc, +LedgerHandle.SyncAddCallback.addComplete(int rc, LedgerHandle lh, - long entryId, - Object ctx)  + long entry, + Object ctx) +
Implementation of callback interface for synchronous read method.
+ void -AsyncCallback.AddCallback.addComplete(int rc, +LedgerRecoveryOp.addComplete(int rc, LedgerHandle lh, long entryId, - Object ctx) -
Callback declaration
- + Object ctx)  void -LedgerHandle.LastAddConfirmedCallback.addLacComplete(int rc, +AsyncCallback.AddLacCallback.addLacComplete(int rc, LedgerHandle lh, Object ctx) -
Implementation of callback interface for synchronous read method.
+
Callback declaration
void -AsyncCallback.AddLacCallback.addLacComplete(int rc, +LedgerHandle.LastAddConfirmedCallback.addLacComplete(int rc, LedgerHandle lh, Object ctx) -
Callback declaration
+
Implementation of callback interface for synchronous read method.
@@ -349,24 +349,24 @@ void -LedgerHandle.NoopCloseCallback.closeComplete(int rc, +AsyncCallback.CloseCallback.closeComplete(int rc, LedgerHandle lh, - Object ctx)  + Object ctx) +
Callback definition
+ void -LedgerHandle.SyncCloseCallback.closeComplete(int rc, +LedgerHandle.NoopCloseCallback.closeComplete(int rc, LedgerHandle lh, - Object ctx) -
Close callback method
- + Object ctx)  void -AsyncCallback.CloseCallback.closeComplete(int rc, +LedgerHandle.SyncCloseCallback.closeComplete(int rc, LedgerHandle lh, Object ctx) -
Callback definition
+
Close callback method
@@ -411,20 +411,20 @@ void -LedgerHandle.SyncReadCallback.readComplete(int rc, +AsyncCallback.ReadCallback.readComplete(int rc, LedgerHandle lh, Enumeration<LedgerEntry> seq, Object ctx) -
Implementation of callback interface for synchronous read method.
+
Callback declaration
void -AsyncCallback.ReadCallback.readComplete(int rc, +LedgerHandle.SyncReadCallback.readComplete(int rc, LedgerHandle lh, Enumeration<LedgerEntry> seq, Object ctx) -
Callback declaration
+
Implementation of callback interface for synchronous read method.
diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerMetadata.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerMetadata.html index 780210c..686e9a5 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerMetadata.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerMetadata.html @@ -137,11 +137,11 @@ protected LedgerMetadata -PendingReadOp.getLedgerMetadata()  +LedgerRecoveryOp.RecoveryReadOp.getLedgerMetadata()  protected LedgerMetadata -LedgerRecoveryOp.RecoveryReadOp.getLedgerMetadata()  +PendingReadOp.getLedgerMetadata()  protected LedgerMetadata @@ -192,16 +192,16 @@ void +BookKeeperAdmin.ReadMetadataCallback.operationComplete(int rc, + LedgerMetadata result)  + + +void LedgerOpenOp.operationComplete(int rc, LedgerMetadata metadata)
Implements Open Ledger Callback.
- -void -BookKeeperAdmin.ReadMetadataCallback.operationComplete(int rc, - LedgerMetadata result)  - (package private) static LedgerMetadata LedgerMetadata.parseVersion1Config(LedgerMetadata lc, diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ReadLastConfirmedOp.LastConfirmedDataCallback.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ReadLastConfirmedOp.LastConfirmedDataCallback.html index 1039720..edbd26a 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ReadLastConfirmedOp.LastConfirmedDataCallback.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/ReadLastConfirmedOp.LastConfirmedDataCallback.html @@ -106,11 +106,11 @@ (package private) ReadLastConfirmedOp.LastConfirmedDataCallback -ReadLastConfirmedOp.cb  +TryReadLastConfirmedOp.cb  (package private) ReadLastConfirmedOp.LastConfirmedDataCallback -TryReadLastConfirmedOp.cb  +ReadLastConfirmedOp.cb  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/TopologyAwareEnsemblePlacementPolicy.BookieNode.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/TopologyAwareEnsemblePlacementPolicy.BookieNode.html index c79c074..c55e828 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/TopologyAwareEnsemblePlacementPolicy.BookieNode.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/class-use/TopologyAwareEnsemblePlacementPolicy.BookieNode.html @@ -156,14 +156,14 @@ TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  @@ -294,7 +294,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -303,7 +303,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -312,7 +312,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -321,7 +321,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -380,28 +380,28 @@ TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/package-tree.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/package-tree.html index 65b73ab..0b57a15 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/package-tree.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/client/package-tree.html @@ -290,8 +290,8 @@ diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/conf/class-use/ClientConfiguration.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/conf/class-use/ClientConfiguration.html index 8fe2490..b8a2423 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/conf/class-use/ClientConfiguration.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/conf/class-use/ClientConfiguration.html @@ -151,24 +151,24 @@ -EnsemblePlacementPolicy -DefaultEnsemblePlacementPolicy.initialize(RackawareEnsemblePlacementPolicyImpl +RackawareEnsemblePlacementPolicyImpl.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger)  -RackawareEnsemblePlacementPolicyImpl -RackawareEnsemblePlacementPolicyImpl.initialize(RegionAwareEnsemblePlacementPolicy +RegionAwareEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger)  -RegionAwareEnsemblePlacementPolicy -RegionAwareEnsemblePlacementPolicy.initialize(EnsemblePlacementPolicy +DefaultEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/feature/class-use/FeatureProvider.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/feature/class-use/FeatureProvider.html index 79261e4..938df33 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/feature/class-use/FeatureProvider.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/feature/class-use/FeatureProvider.html @@ -109,17 +109,17 @@ -protected FeatureProvider -RegionAwareEnsemblePlacementPolicy.featureProvider  - - (package private) FeatureProvider BookKeeper.featureProvider  - + (package private) FeatureProvider BookKeeper.Builder.featureProvider  + +protected FeatureProvider +RegionAwareEnsemblePlacementPolicy.featureProvider  + @@ -136,24 +136,24 @@ - - + - - + - - + - + - + - +
EnsemblePlacementPolicyDefaultEnsemblePlacementPolicy.initialize(RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger) 
RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(RegionAwareEnsemblePlacementPolicyRegionAwareEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger) 
RegionAwareEnsemblePlacementPolicyRegionAwareEnsemblePlacementPolicy.initialize(EnsemblePlacementPolicyDefaultEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/Counter.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/Counter.html index 78b5cd7..32afb95 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/Counter.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/Counter.html @@ -198,15 +198,15 @@
CounterCachingStatsLogger.getCounter(String name) NullStatsLogger.getCounter(String name) 
CounterStatsLogger.getCounter(String name) CachingStatsLogger.getCounter(String name) 
CounterNullStatsLogger.getCounter(String name) StatsLogger.getCounter(String name) 
diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/Gauge.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/Gauge.html index 45057ec..074f438 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/Gauge.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/Gauge.html @@ -134,21 +134,21 @@ <T extends Number>
void -CachingStatsLogger.registerGauge(String name, +NullStatsLogger.registerGauge(String name, Gauge<T> gauge)  <T extends Number>
void +CachingStatsLogger.registerGauge(String name, + Gauge<T> gauge)  + + +<T extends Number>
void StatsLogger.registerGauge(String name, Gauge<T> gauge)
Register given gauge as name name.
- -<T extends Number>
void -NullStatsLogger.registerGauge(String name, - Gauge<T> gauge)  - <T extends Number>
void PrometheusStatsLogger.unregisterGauge(String name, @@ -161,21 +161,21 @@ <T extends Number>
void -CachingStatsLogger.unregisterGauge(String name, +NullStatsLogger.unregisterGauge(String name, Gauge<T> gauge)  <T extends Number>
void +CachingStatsLogger.unregisterGauge(String name, + Gauge<T> gauge)  + + +<T extends Number>
void StatsLogger.unregisterGauge(String name, Gauge<T> gauge)
Unregister given gauge from name name.
- -<T extends Number>
void -NullStatsLogger.unregisterGauge(String name, - Gauge<T> gauge)  - diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsData.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsData.html index b2f9a57..088f6ee 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsData.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsData.html @@ -147,11 +147,11 @@ OpStatsData -OpStatsLogger.toOpStatsData()  +NullStatsLogger.NullOpStatsLogger.toOpStatsData()  OpStatsData -NullStatsLogger.NullOpStatsLogger.toOpStatsData()  +OpStatsLogger.toOpStatsData()  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsLogger.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsLogger.html index 9326334..a7fbcb3 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsLogger.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsLogger.html @@ -271,15 +271,15 @@ OpStatsLogger -CachingStatsLogger.getOpStatsLogger(String name)  +NullStatsLogger.getOpStatsLogger(String name)  OpStatsLogger -StatsLogger.getOpStatsLogger(String name)  +CachingStatsLogger.getOpStatsLogger(String name)  OpStatsLogger -NullStatsLogger.getOpStatsLogger(String name)  +StatsLogger.getOpStatsLogger(String name)  diff --git a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsLogger.html b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsLogger.html index 5f80af7..36f899c 100644 --- a/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsLogger.html +++ b/content/docs/4.5.0/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsLogger.html @@ -129,13 +129,13 @@ -protected StatsLogger -RackawareEnsemblePlacementPolicyImpl.statsLogger  - - (package private) StatsLogger BookKeeper.Builder.statsLogger  + +protected StatsLogger +RackawareEnsemblePlacementPolicyImpl.statsLogger  + @@ -159,24 +159,24 @@ - - + - - + - - + - - + + StatsLogger statsLogger) +
Initialize the policy.
+ - - + + StatsLogger statsLogger)  @@ -341,14 +341,14 @@ - - - - + + + + @@ -359,17 +359,17 @@ - + - + - +
EnsemblePlacementPolicyDefaultEnsemblePlacementPolicy.initialize(RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger) 
RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(RegionAwareEnsemblePlacementPolicyRegionAwareEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger) 
RegionAwareEnsemblePlacementPolicyRegionAwareEnsemblePlacementPolicy.initialize(EnsemblePlacementPolicyDefaultEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, @@ -193,26 +193,26 @@
protected RackawareEnsemblePlacementPolicyRackawareEnsemblePlacementPolicy.initialize(org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver, +protected RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, boolean isWeighted, int maxWeightMultiple, - StatsLogger statsLogger) 
protected RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver, +protected RackawareEnsemblePlacementPolicyRackawareEnsemblePlacementPolicy.initialize(org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, boolean isWeighted, int maxWeightMultiple, - StatsLogger statsLogger) -
Initialize the policy.
-
BookKeeper.Builder
StatsLoggerNullStatsProvider.getStatsLogger(String scope) 
StatsLogger StatsProvider.getStatsLogger(String scope)
Return the stats logger to a given scope.
StatsLoggerNullStatsProvider.getStatsLogger(String scope) 
StatsLogger PrometheusStatsLogger.scope(String name) 
StatsLoggerCachingStatsLogger.scope(String name) NullStatsLogger.scope(String name) 
StatsLoggerStatsLogger.scope(String name) -
Provide the stats logger under scope name.
-		CachingStatsLogger.scope(String name) 
StatsLoggerNullStatsLogger.scope(String name) StatsLogger.scope(String name) +
Provide the stats logger under scope name.
+
@@ -392,21 +392,21 @@ void -CachingStatsLogger.removeScope(String name, +NullStatsLogger.removeScope(String name, StatsLogger statsLogger)  void +CachingStatsLogger.removeScope(String name, + StatsLogger statsLogger)  + + +void StatsLogger.removeScope(String name, StatsLogger statsLogger)
Remove the given statsLogger for scope name.
- -void -NullStatsLogger.removeScope(String name, - StatsLogger statsLogger)  - diff --git a/content/docs/4.5.0/api/javadoc/overview-tree.html b/content/docs/4.5.0/api/javadoc/overview-tree.html index abdc5bc..33c716c 100644 --- a/content/docs/4.5.0/api/javadoc/overview-tree.html +++ b/content/docs/4.5.0/api/javadoc/overview-tree.html @@ -374,8 +374,8 @@ diff --git a/content/docs/latest/api/javadoc/allclasses-frame.html b/content/docs/latest/api/javadoc/allclasses-frame.html index f467386..73ce4e5 100644 --- a/content/docs/latest/api/javadoc/allclasses-frame.html +++ b/content/docs/latest/api/javadoc/allclasses-frame.html @@ -155,11 +155,11 @@
  • PendingReadLacOp.LacCallback
  • PendingReadOp
  • PendingWriteLacOp
    • -
  • PrometheusCounter
    • -
  • PrometheusMetricsProvider
    • -
  • PrometheusOpStatsLogger
    • -
  • PrometheusStatsLogger
    • -
  • PrometheusUtil
    • +
  • PrometheusCounter
    • +
  • PrometheusMetricsProvider
    • +
  • PrometheusOpStatsLogger
    • +
  • PrometheusStatsLogger
    • +
  • PrometheusUtil
  • RackawareEnsemblePlacementPolicy
  • RackawareEnsemblePlacementPolicyImpl
  • RackawareEnsemblePlacementPolicyImpl.DefaultResolver
    • diff --git a/content/docs/latest/api/javadoc/allclasses-noframe.html b/content/docs/latest/api/javadoc/allclasses-noframe.html index e3a33ca..41ffa7c 100644 --- a/content/docs/latest/api/javadoc/allclasses-noframe.html +++ b/content/docs/latest/api/javadoc/allclasses-noframe.html @@ -155,11 +155,11 @@
  • PendingReadLacOp.LacCallback
  • PendingReadOp
  • PendingWriteLacOp
    • -
  • PrometheusCounter
    • -
  • PrometheusMetricsProvider
    • -
  • PrometheusOpStatsLogger
    • -
  • PrometheusStatsLogger
    • -
  • PrometheusUtil
    • +
  • PrometheusCounter
    • +
  • PrometheusMetricsProvider
    • +
  • PrometheusOpStatsLogger
    • +
  • PrometheusStatsLogger
    • +
  • PrometheusUtil
  • RackawareEnsemblePlacementPolicy
  • RackawareEnsemblePlacementPolicyImpl
  • RackawareEnsemblePlacementPolicyImpl.DefaultResolver
    • diff --git a/content/docs/latest/api/javadoc/index-all.html b/content/docs/latest/api/javadoc/index-all.html index d4292a5..581d816 100644 --- a/content/docs/latest/api/javadoc/index-all.html +++ b/content/docs/latest/api/javadoc/index-all.html @@ -92,7 +92,7 @@
    add(long) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
     
    -
    add(long) - Method in class org.apache.bookkeeper.stats.PrometheusCounter
    +
    add(long) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusCounter
     
    add(long) - Method in class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl
     
    @@ -831,9 +831,9 @@
    Clear stats for this operation.
    -
    clear() - Method in class org.apache.bookkeeper.stats.PrometheusCounter
    +
    clear() - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusCounter
     
    -
    clear() - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger
    +
    clear() - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger
     
    clear() - Method in class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl
     
    @@ -1104,7 +1104,7 @@
    dec() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
     
    -
    dec() - Method in class org.apache.bookkeeper.stats.PrometheusCounter
    +
    dec() - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusCounter
     
    dec() - Method in class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl
     
    @@ -1500,7 +1500,7 @@
    get() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
     
    -
    get() - Method in class org.apache.bookkeeper.stats.PrometheusCounter
    +
    get() - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusCounter
     
    get() - Static method in class org.apache.bookkeeper.stats.Stats
     
    @@ -1697,7 +1697,7 @@
     
    getCounter(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
     
    -
    getCounter(String) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger
    +
    getCounter(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
     
    getCounter(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger
     
    @@ -2201,7 +2201,7 @@
     
    getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
     
    -
    getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger
    +
    getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
     
    getOpStatsLogger(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger
     
    @@ -2396,7 +2396,7 @@
     
    getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.NullStatsProvider
     
    -
    getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.PrometheusMetricsProvider
    +
    getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
     
    getStatsLogger(String) - Method in interface org.apache.bookkeeper.stats.StatsProvider
    @@ -2673,7 +2673,7 @@
    inc() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
     
    -
    inc() - Method in class org.apache.bookkeeper.stats.PrometheusCounter
    +
    inc() - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusCounter
     
    inc() - Method in class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl
     
    @@ -3749,6 +3749,10 @@
    A lightweight stats library used for exporting bookkeeper stats.
    +
    org.apache.bookkeeper.stats.prometheus - package org.apache.bookkeeper.stats.prometheus
    +
    +
    A stats provider implementation based on https://prometheus.io/.
    +
    org.apache.bookkeeper.stats.twitter.finagle - package org.apache.bookkeeper.stats.twitter.finagle
    A stats provider implemented based on finagle stats library.
    @@ -3897,35 +3901,35 @@
     
    processResult(int, String, Object) - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback
     
    -
    PrometheusCounter - Class in org.apache.bookkeeper.stats
    +
    PrometheusCounter - Class in org.apache.bookkeeper.stats.prometheus
    A Counter implementation based on Prometheus metrics library.
    -
    PrometheusCounter(CollectorRegistry, String) - Constructor for class org.apache.bookkeeper.stats.PrometheusCounter
    +
    PrometheusCounter(CollectorRegistry, String) - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusCounter
     
    -
    PrometheusMetricsProvider - Class in org.apache.bookkeeper.stats
    +
    PrometheusMetricsProvider - Class in org.apache.bookkeeper.stats.prometheus
    A Prometheus based StatsProvider implementation.
    -
    PrometheusMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.PrometheusMetricsProvider
    +
    PrometheusMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
     
    -
    PrometheusOpStatsLogger - Class in org.apache.bookkeeper.stats
    +
    PrometheusOpStatsLogger - Class in org.apache.bookkeeper.stats.prometheus
    A Prometheus based OpStatsLogger implementation.
    -
    PrometheusOpStatsLogger(CollectorRegistry, String) - Constructor for class org.apache.bookkeeper.stats.PrometheusOpStatsLogger
    +
    PrometheusOpStatsLogger(CollectorRegistry, String) - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger
     
    -
    PrometheusStatsLogger - Class in org.apache.bookkeeper.stats
    +
    PrometheusStatsLogger - Class in org.apache.bookkeeper.stats.prometheus
    A Prometheus based StatsLogger implementation.
    -
    PrometheusStatsLogger(CollectorRegistry, String) - Constructor for class org.apache.bookkeeper.stats.PrometheusStatsLogger
    +
    PrometheusStatsLogger(CollectorRegistry, String) - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
     
    -
    PrometheusUtil - Class in org.apache.bookkeeper.stats
    +
    PrometheusUtil - Class in org.apache.bookkeeper.stats.prometheus
    Container for Prometheus utility methods.
    -
    PrometheusUtil() - Constructor for class org.apache.bookkeeper.stats.PrometheusUtil
    +
    PrometheusUtil() - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusUtil
     
    ProtocolVersionException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
    @@ -4210,7 +4214,7 @@
    Increment the failed op counter with the given eventLatency.
    -
    registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger
    +
    registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger
     
    registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl
     
    @@ -4226,7 +4230,7 @@
    An operation with the given value failed.
    -
    registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger
    +
    registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger
     
    registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl
     
    @@ -4240,7 +4244,7 @@
     
    registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
     
    -
    registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger
    +
    registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
     
    registerGauge(String, Gauge<T>) - Method in interface org.apache.bookkeeper.stats.StatsLogger
    @@ -4262,7 +4266,7 @@
    An operation succeeded with the given eventLatency.
    -
    registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger
    +
    registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger
     
    registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl
     
    @@ -4278,7 +4282,7 @@
    An operation with the given value succeeded.
    -
    registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger
    +
    registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger
     
    registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl
     
    @@ -4304,7 +4308,7 @@
     
    removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
     
    -
    removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger
    +
    removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
     
    removeScope(String, StatsLogger) - Method in interface org.apache.bookkeeper.stats.StatsLogger
    @@ -4474,7 +4478,7 @@
    Implements Delete Callback.
    -
    safeRegister(CollectorRegistry, T) - Static method in class org.apache.bookkeeper.stats.PrometheusUtil
    +
    safeRegister(CollectorRegistry, T) - Static method in class org.apache.bookkeeper.stats.prometheus.PrometheusUtil
     
    safeRun() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle.MetadataUpdater
     
    @@ -4500,7 +4504,7 @@
     
    scope(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
     
    -
    scope(String) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger
    +
    scope(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
     
    scope(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger
    @@ -5417,7 +5421,7 @@
     
    start(Configuration) - Method in class org.apache.bookkeeper.stats.NullStatsProvider
     
    -
    start(Configuration) - Method in class org.apache.bookkeeper.stats.PrometheusMetricsProvider
    +
    start(Configuration) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
     
    start(Configuration) - Method in interface org.apache.bookkeeper.stats.StatsProvider
    @@ -5485,7 +5489,7 @@
     
    stop() - Method in class org.apache.bookkeeper.stats.NullStatsProvider
     
    -
    stop() - Method in class org.apache.bookkeeper.stats.PrometheusMetricsProvider
    +
    stop() - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
     
    stop() - Method in interface org.apache.bookkeeper.stats.StatsProvider
    @@ -5621,7 +5625,7 @@
     
    toOpStatsData() - Method in interface org.apache.bookkeeper.stats.OpStatsLogger
     
    -
    toOpStatsData() - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger
    +
    toOpStatsData() - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger
     
    toOpStatsData() - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl
    @@ -5766,7 +5770,7 @@
     
    unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
     
    -
    unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger
    +
    unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
     
    unregisterGauge(String, Gauge<T>) - Method in interface org.apache.bookkeeper.stats.StatsLogger
    diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.AddCallback.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.AddCallback.html index 0f46362..176d60b 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.AddCallback.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.AddCallback.html @@ -138,27 +138,19 @@
    - - - - - + - - + - + + + + + - - - - + + + + - - - - - - - - - - - - diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.html index 1193c65..f9567a6 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.html @@ -258,21 +258,15 @@ - - - - - + - + - + + + + + - + @@ -341,9 +343,7 @@ - + @@ -436,15 +436,15 @@ - - - - + + + + @@ -457,25 +457,25 @@ + + + + - + - + - + - - - - - + - + - + @@ -122,7 +122,7 @@ - +
    voidReadOnlyLedgerHandle.asyncAddEntry(byte[] data, - AsyncCallback.AddCallback cb, - Object ctx) 
    void LedgerHandle.asyncAddEntry(byte[] data, AsyncCallback.AddCallback cb, Object ctx)
    Add entry asynchronously to an open ledger.
    voidReadOnlyLedgerHandle.asyncAddEntry(byte[] data, - int offset, - int length, +ReadOnlyLedgerHandle.asyncAddEntry(byte[] data, AsyncCallback.AddCallback cb, Object ctx) 
    void LedgerHandle.asyncAddEntry(byte[] data, int offset, @@ -168,7 +160,7 @@
    Add entry asynchronously to an open ledger, using an offset and range.
    void LedgerHandleAdv.asyncAddEntry(byte[] data, int offset, @@ -178,6 +170,14 @@
    LedgerHandleAdv will not allow addEntry without providing an entryId
    voidReadOnlyLedgerHandle.asyncAddEntry(byte[] data, + int offset, + int length, + AsyncCallback.AddCallback cb, + Object ctx) 
    void LedgerHandle.asyncAddEntry(io.netty.buffer.ByteBuf data, diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.CloseCallback.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.CloseCallback.html index 048b714..00d9aab 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.CloseCallback.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/AsyncCallback.CloseCallback.html @@ -123,16 +123,16 @@
    voidReadOnlyLedgerHandle.asyncClose(AsyncCallback.CloseCallback cb, - Object ctx) 
    void LedgerHandle.asyncClose(AsyncCallback.CloseCallback cb, Object ctx)
    Asynchronous close, any adds in flight will return errors.
    voidReadOnlyLedgerHandle.asyncClose(AsyncCallback.CloseCallback cb, + Object ctx) 
    (package private) void LedgerHandle.asyncCloseInternal(AsyncCallback.CloseCallback cb, diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.BKNotEnoughBookiesException.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.BKNotEnoughBookiesException.html index 5986e99..64a5dd7 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.BKNotEnoughBookiesException.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BKException.BKNotEnoughBookiesException.html @@ -115,7 +115,7 @@
    ArrayList<org.apache.bookkeeper.net.BookieSocketAddress>RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -123,23 +123,23 @@
    ArrayList<org.apache.bookkeeper.net.BookieSocketAddress>DefaultEnsemblePlacementPolicy.newEnsemble(int ensembleSize, - int quorumSize, +RegionAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, + int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies) 
    ArrayList<org.apache.bookkeeper.net.BookieSocketAddress>RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, - int writeQuorumSize, +DefaultEnsemblePlacementPolicy.newEnsemble(int ensembleSize, + int quorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies) 
    ArrayList<org.apache.bookkeeper.net.BookieSocketAddress>RegionAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -168,7 +168,7 @@
    ArrayList<org.apache.bookkeeper.net.BookieSocketAddress>RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -177,7 +177,7 @@
    ArrayList<org.apache.bookkeeper.net.BookieSocketAddress>RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -203,7 +203,7 @@
    org.apache.bookkeeper.net.BookieSocketAddressRackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -213,7 +213,7 @@
    org.apache.bookkeeper.net.BookieSocketAddressDefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize, +RegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -223,7 +223,7 @@
    org.apache.bookkeeper.net.BookieSocketAddressRackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, +DefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -233,7 +233,7 @@
    org.apache.bookkeeper.net.BookieSocketAddressRegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, +RackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, @@ -289,14 +289,14 @@
    TopologyAwareEnsemblePlacementPolicy.BookieNodeRackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble) 
    TopologyAwareEnsemblePlacementPolicy.BookieNodeRackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble) 
    longReadOnlyLedgerHandle.addEntry(byte[] data) 
    long LedgerHandle.addEntry(byte[] data)
    Add entry synchronously to an open ledger.
    longReadOnlyLedgerHandle.addEntry(byte[] data, - int offset, - int length) ReadOnlyLedgerHandle.addEntry(byte[] data) 
    long LedgerHandle.addEntry(byte[] data, int offset, @@ -280,6 +274,12 @@
    Add entry synchronously to an open ledger.
    longReadOnlyLedgerHandle.addEntry(byte[] data, + int offset, + int length) 
    long LedgerHandle.addEntry(long entryId, @@ -325,7 +325,9 @@
    voidReadOnlyLedgerHandle.close() BookKeeper.close() +
    Shuts down client.
    +
    void
    voidBookKeeper.close() -
    Shuts down client.
    -    		ReadOnlyLedgerHandle.close() 
    LedgerHandle
    (package private) Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo>BookieInfoReader.getBookieInfo() 
    Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> BookKeeper.getBookieInfo()
    Retrieves BookieInfo from all the bookies in the cluster.
    (package private) Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo>BookieInfoReader.getBookieInfo() 
    Collection<org.apache.bookkeeper.net.BookieSocketAddress> BookieWatcher.getBookies() 
    (package private) voidBookieWatcher.notifyBookiesChanged(BookiesListener listener) 
    void BookKeeperAdmin.notifyBookiesChanged(BookiesListener listener)
    Notify when the available list of bookies changes.
    (package private) voidBookieWatcher.notifyBookiesChanged(BookiesListener listener) BookieWatcher.notifyReadOnlyBookiesChanged(BookiesListener listener) 
    void BookKeeperAdmin.notifyReadOnlyBookiesChanged(BookiesListener listener)
    Notify when the available list of read only bookies changes.
    (package private) voidBookieWatcher.notifyReadOnlyBookiesChanged(BookiesListener listener) 
    LedgerHandle BookKeeperAdmin.openLedger(long lId) diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookKeeper.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookKeeper.html index f1aecf4..2e80e5e 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookKeeper.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookKeeper.html @@ -106,15 +106,15 @@
    (package private) BookKeeperLedgerCreateOp.bk BookieWatcher.bk 
    (package private) BookKeeperLedgerHandle.bk LedgerCreateOp.bk 
    (package private) BookKeeperLedgerDeleteOp.bk LedgerHandle.bk 
    (package private) BookKeeper
    (package private) BookKeeperBookieWatcher.bk LedgerDeleteOp.bk 
    diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookieInfoReader.BookieInfo.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookieInfoReader.BookieInfo.html index 4ea8720..fba85ef 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookieInfoReader.BookieInfo.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookieInfoReader.BookieInfo.html @@ -105,15 +105,15 @@ -(package private) Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> -BookieInfoReader.getBookieInfo()  - - Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> BookKeeper.getBookieInfo()
    Retrieves BookieInfo from all the bookies in the cluster.
    + +(package private) Map<org.apache.bookkeeper.net.BookieSocketAddress,BookieInfoReader.BookieInfo> +BookieInfoReader.getBookieInfo()  + @@ -125,11 +125,11 @@ - - diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookiesListener.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookiesListener.html index 7e60a9f..8b7030b 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookiesListener.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/BookiesListener.html @@ -105,25 +105,25 @@ + + + + - + - + - + - - - -
    voidDefaultEnsemblePlacementPolicy.updateBookieInfo(Map<org.apache.bookkeeper.net.BookieSocketAddress,RackawareEnsemblePlacementPolicyImpl.updateBookieInfo(Map<org.apache.bookkeeper.net.BookieSocketAddress, voidRackawareEnsemblePlacementPolicyImpl.updateBookieInfo(Map<org.apache.bookkeeper.net.BookieSocketAddress,DefaultEnsemblePlacementPolicy.updateBookieInfo(Map<org.apache.bookkeeper.net.BookieSocketAddress, default void
    (package private) voidBookieWatcher.notifyBookiesChanged(BookiesListener listener) 
    void BookKeeperAdmin.notifyBookiesChanged(BookiesListener listener)
    Notify when the available list of bookies changes.
    (package private) voidBookieWatcher.notifyBookiesChanged(BookiesListener listener) BookieWatcher.notifyReadOnlyBookiesChanged(BookiesListener listener) 
    void BookKeeperAdmin.notifyReadOnlyBookiesChanged(BookiesListener listener)
    Notify when the available list of read only bookies changes.
    (package private) voidBookieWatcher.notifyReadOnlyBookiesChanged(BookiesListener listener) 
    diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DigestManager.RecoveryData.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DigestManager.RecoveryData.html index 98433fc..beecd5a 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DigestManager.RecoveryData.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DigestManager.RecoveryData.html @@ -106,11 +106,11 @@ (package private) DigestManager.RecoveryData -ReadLastConfirmedOp.maxRecoveredData  +TryReadLastConfirmedOp.maxRecoveredData  (package private) DigestManager.RecoveryData -TryReadLastConfirmedOp.maxRecoveredData  +ReadLastConfirmedOp.maxRecoveredData  diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.AckSet.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.AckSet.html index 8358957..f00afc5 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.AckSet.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.AckSet.html @@ -106,11 +106,11 @@ (package private) DistributionSchedule.AckSet -PendingAddOp.ackSet  +PendingWriteLacOp.ackSet  (package private) DistributionSchedule.AckSet -PendingWriteLacOp.ackSet  +PendingAddOp.ackSet  diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.QuorumCoverageSet.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.QuorumCoverageSet.html index 8514d5a..fa6fc30 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.QuorumCoverageSet.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/DistributionSchedule.QuorumCoverageSet.html @@ -106,11 +106,11 @@ (package private) DistributionSchedule.QuorumCoverageSet -PendingReadLacOp.coverageSet  +ReadLastConfirmedOp.coverageSet  (package private) DistributionSchedule.QuorumCoverageSet -ReadLastConfirmedOp.coverageSet  +PendingReadLacOp.coverageSet  diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/EnsemblePlacementPolicy.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/EnsemblePlacementPolicy.html index 1845a8d..9a50212 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/EnsemblePlacementPolicy.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/EnsemblePlacementPolicy.html @@ -162,11 +162,11 @@ (package private) EnsemblePlacementPolicy -BookKeeper.placementPolicy  +BookieWatcher.placementPolicy  (package private) EnsemblePlacementPolicy -BookieWatcher.placementPolicy  +BookKeeper.placementPolicy  diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Ensemble.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Ensemble.html index 661a4d2..fa9d4c4 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Ensemble.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Ensemble.html @@ -165,7 +165,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -174,7 +174,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -217,14 +217,14 @@ TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Predicate.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Predicate.html index 63a4bcc..d3c637d 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Predicate.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ITopologyAwareEnsemblePlacementPolicy.Predicate.html @@ -150,7 +150,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -159,7 +159,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -202,14 +202,14 @@ TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerEntry.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerEntry.html index 3e8b06b..44e0d79 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerEntry.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerEntry.html @@ -169,11 +169,11 @@ LedgerEntry -PendingReadOp.nextElement()  +ListenerBasedPendingReadOp.nextElement()  LedgerEntry -ListenerBasedPendingReadOp.nextElement()  +PendingReadOp.nextElement()  @@ -259,20 +259,20 @@ void -LedgerHandle.SyncReadCallback.readComplete(int rc, +AsyncCallback.ReadCallback.readComplete(int rc, LedgerHandle lh, Enumeration<LedgerEntry> seq, Object ctx) -
    Implementation of callback interface for synchronous read method.
    +
    Callback declaration
    void -AsyncCallback.ReadCallback.readComplete(int rc, +LedgerHandle.SyncReadCallback.readComplete(int rc, LedgerHandle lh, Enumeration<LedgerEntry> seq, Object ctx) -
    Callback declaration
    +
    Implementation of callback interface for synchronous read method.
    diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerHandle.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerHandle.html index 1f6ee6b..2139412 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerHandle.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerHandle.html @@ -132,51 +132,51 @@ (package private) LedgerHandle -SyncCounter.lh  +PendingWriteLacOp.lh  (package private) LedgerHandle -LedgerCreateOp.lh  +TryReadLastConfirmedOp.lh  (package private) LedgerHandle -PendingReadOp.lh  +PendingAddOp.lh  (package private) LedgerHandle -PendingReadLacOp.lh  +ReadLastConfirmedOp.lh  (package private) LedgerHandle -ReadLastConfirmedOp.lh  +ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl.lh  (package private) LedgerHandle -LedgerOpenOp.lh  +LedgerFragmentReplicator.SingleFragmentCallback.lh  (package private) LedgerHandle -ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl.lh  +LedgerCreateOp.lh  (package private) LedgerHandle -TryReadLastConfirmedOp.lh  +SyncCounter.lh  (package private) LedgerHandle -PendingAddOp.lh  +LedgerRecoveryOp.lh  (package private) LedgerHandle -LedgerRecoveryOp.lh  +LedgerOpenOp.lh  (package private) LedgerHandle -PendingWriteLacOp.lh  +PendingReadOp.lh  (package private) LedgerHandle -LedgerFragmentReplicator.SingleFragmentCallback.lh  +PendingReadLacOp.lh  @@ -300,43 +300,43 @@ void -LedgerHandle.SyncAddCallback.addComplete(int rc, +AsyncCallback.AddCallback.addComplete(int rc, LedgerHandle lh, - long entry, + long entryId, Object ctx) -
    Implementation of callback interface for synchronous read method.
    +
    Callback declaration
    void -LedgerRecoveryOp.addComplete(int rc, +LedgerHandle.SyncAddCallback.addComplete(int rc, LedgerHandle lh, - long entryId, - Object ctx)  + long entry, + Object ctx) +
    Implementation of callback interface for synchronous read method.
    + void -AsyncCallback.AddCallback.addComplete(int rc, +LedgerRecoveryOp.addComplete(int rc, LedgerHandle lh, long entryId, - Object ctx) -
    Callback declaration
    - + Object ctx)      void -LedgerHandle.LastAddConfirmedCallback.addLacComplete(int rc, +AsyncCallback.AddLacCallback.addLacComplete(int rc, LedgerHandle lh, Object ctx) -
    Implementation of callback interface for synchronous read method.
    +
    Callback declaration
    void -AsyncCallback.AddLacCallback.addLacComplete(int rc, +LedgerHandle.LastAddConfirmedCallback.addLacComplete(int rc, LedgerHandle lh, Object ctx) -
    Callback declaration
    +
    Implementation of callback interface for synchronous read method.
    @@ -349,24 +349,24 @@ void -LedgerHandle.NoopCloseCallback.closeComplete(int rc, +AsyncCallback.CloseCallback.closeComplete(int rc, LedgerHandle lh, - Object ctx)  + Object ctx) +
    Callback definition
    + void -LedgerHandle.SyncCloseCallback.closeComplete(int rc, +LedgerHandle.NoopCloseCallback.closeComplete(int rc, LedgerHandle lh, - Object ctx) -
    Close callback method
    - + Object ctx)      void -AsyncCallback.CloseCallback.closeComplete(int rc, +LedgerHandle.SyncCloseCallback.closeComplete(int rc, LedgerHandle lh, Object ctx) -
    Callback definition
    +
    Close callback method
    @@ -411,20 +411,20 @@ void -LedgerHandle.SyncReadCallback.readComplete(int rc, +AsyncCallback.ReadCallback.readComplete(int rc, LedgerHandle lh, Enumeration<LedgerEntry> seq, Object ctx) -
    Implementation of callback interface for synchronous read method.
    +
    Callback declaration
    void -AsyncCallback.ReadCallback.readComplete(int rc, +LedgerHandle.SyncReadCallback.readComplete(int rc, LedgerHandle lh, Enumeration<LedgerEntry> seq, Object ctx) -
    Callback declaration
    +
    Implementation of callback interface for synchronous read method.
    diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerMetadata.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerMetadata.html index 16ff9ee..266aed4 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerMetadata.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/LedgerMetadata.html @@ -137,11 +137,11 @@ protected LedgerMetadata -PendingReadOp.getLedgerMetadata()  +LedgerRecoveryOp.RecoveryReadOp.getLedgerMetadata()  protected LedgerMetadata -LedgerRecoveryOp.RecoveryReadOp.getLedgerMetadata()  +PendingReadOp.getLedgerMetadata()  protected LedgerMetadata @@ -192,16 +192,16 @@ void +BookKeeperAdmin.ReadMetadataCallback.operationComplete(int rc, + LedgerMetadata result)  + + +void LedgerOpenOp.operationComplete(int rc, LedgerMetadata metadata)
    Implements Open Ledger Callback.
    - -void -BookKeeperAdmin.ReadMetadataCallback.operationComplete(int rc, - LedgerMetadata result)  - (package private) static LedgerMetadata LedgerMetadata.parseVersion1Config(LedgerMetadata lc, diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ReadLastConfirmedOp.LastConfirmedDataCallback.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ReadLastConfirmedOp.LastConfirmedDataCallback.html index 42a8f8f..aaf314d 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ReadLastConfirmedOp.LastConfirmedDataCallback.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/ReadLastConfirmedOp.LastConfirmedDataCallback.html @@ -106,11 +106,11 @@ (package private) ReadLastConfirmedOp.LastConfirmedDataCallback -ReadLastConfirmedOp.cb  +TryReadLastConfirmedOp.cb  (package private) ReadLastConfirmedOp.LastConfirmedDataCallback -TryReadLastConfirmedOp.cb  +ReadLastConfirmedOp.cb  diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/TopologyAwareEnsemblePlacementPolicy.BookieNode.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/TopologyAwareEnsemblePlacementPolicy.BookieNode.html index cd1c726..9c5cc1c 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/TopologyAwareEnsemblePlacementPolicy.BookieNode.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/class-use/TopologyAwareEnsemblePlacementPolicy.BookieNode.html @@ -156,14 +156,14 @@ TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  @@ -294,7 +294,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -303,7 +303,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -312,7 +312,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -321,7 +321,7 @@ ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> -RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, +RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<org.apache.bookkeeper.net.BookieSocketAddress> excludeBookies, @@ -380,28 +380,28 @@ TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  TopologyAwareEnsemblePlacementPolicy.BookieNode -RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<org.apache.bookkeeper.net.Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode> ensemble)  diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/package-tree.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/package-tree.html index 07366e9..85d259b 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/package-tree.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/client/package-tree.html @@ -291,8 +291,8 @@ diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/conf/class-use/ClientConfiguration.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/conf/class-use/ClientConfiguration.html index 8318ff4..919b76a 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/conf/class-use/ClientConfiguration.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/conf/class-use/ClientConfiguration.html @@ -151,24 +151,24 @@ -EnsemblePlacementPolicy -DefaultEnsemblePlacementPolicy.initialize(RackawareEnsemblePlacementPolicyImpl +RackawareEnsemblePlacementPolicyImpl.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger)  -RackawareEnsemblePlacementPolicyImpl -RackawareEnsemblePlacementPolicyImpl.initialize(RegionAwareEnsemblePlacementPolicy +RegionAwareEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger)  -RegionAwareEnsemblePlacementPolicy -RegionAwareEnsemblePlacementPolicy.initialize(EnsemblePlacementPolicy +DefaultEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/feature/class-use/FeatureProvider.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/feature/class-use/FeatureProvider.html index 09eefd5..26482d4 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/feature/class-use/FeatureProvider.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/feature/class-use/FeatureProvider.html @@ -109,17 +109,17 @@ -protected FeatureProvider -RegionAwareEnsemblePlacementPolicy.featureProvider  - - (package private) FeatureProvider BookKeeper.featureProvider  - + (package private) FeatureProvider BookKeeper.Builder.featureProvider  + +protected FeatureProvider +RegionAwareEnsemblePlacementPolicy.featureProvider  + @@ -136,24 +136,24 @@ - - + - - + - - + + + + - + - + - - - -
    EnsemblePlacementPolicyDefaultEnsemblePlacementPolicy.initialize(RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger) 
    RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(RegionAwareEnsemblePlacementPolicyRegionAwareEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger) 
    RegionAwareEnsemblePlacementPolicyRegionAwareEnsemblePlacementPolicy.initialize(EnsemblePlacementPolicyDefaultEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/Counter.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/Counter.html index 835ea01..3c61de5 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/Counter.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/Counter.html @@ -101,7 +101,7 @@ var activeTableTab = "activeTableTab";
  • All Known Implementing Classes:
    -
    CounterImpl, CounterImpl, CounterImpl, CounterImpl, CounterImpl, CounterImpl,

    diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/OpStatsLogger.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/OpStatsLogger.html index a9d4999..2f27723 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/OpStatsLogger.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/OpStatsLogger.html @@ -50,7 +50,7 @@ var activeTableTab = "activeTableTab";
    		• org.apache.bookkeeper.stats.prometheus +
    A stats provider implementation based on https://prometheus.io/.
    +
    org.apache.bookkeeper.stats.twitter.finagle
    A stats provider implemented based on finagle stats library.
    org.apache.bookkeeper.stats.twitter.ostrich
    A stats provider implemented based on Twitter Ostrich library.
    org.apache.bookkeeper.stats.twitter.science
    A stats provider implementation based on Twitter Science Stats library.
    @@ -160,12 +166,6 @@
    A no-op Counter.
    class PrometheusCounter -
    A Counter implementation based on Prometheus metrics library.
    -
    @@ -190,11 +190,11 @@ - + - + @@ -204,9 +204,38 @@ + +
    CounterPrometheusStatsLogger.getCounter(String name) CodahaleStatsLogger.getCounter(String statName) 
    CounterCodahaleStatsLogger.getCounter(String statName) NullStatsLogger.getCounter(String name) 
    CounterCounter StatsLogger.getCounter(String name) 
    + +
  • + + +

    Uses of Counter in org.apache.bookkeeper.stats.prometheus

    + + + + + + + + + + + + +
    Classes in org.apache.bookkeeper.stats.prometheus that implement Counter 
    Modifier and TypeClass and Description
    class PrometheusCounter +
    A Counter implementation based on Prometheus metrics library.
    +
    + + + + + + + - +
    Methods in org.apache.bookkeeper.stats.prometheus that return Counter 
    Modifier and TypeMethod and Description
    CounterNullStatsLogger.getCounter(String name) PrometheusStatsLogger.getCounter(String name) 
    diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/Gauge.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/Gauge.html index f4e1bf6..5259553 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/Gauge.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/Gauge.html @@ -89,18 +89,24 @@ +org.apache.bookkeeper.stats.prometheus + +
    A stats provider implementation based on https://prometheus.io/.
    + + + org.apache.bookkeeper.stats.twitter.finagle
    A stats provider implemented based on finagle stats library.
    - + org.apache.bookkeeper.stats.twitter.ostrich
    A stats provider implemented based on Twitter Ostrich library.
    - + org.apache.bookkeeper.stats.twitter.science
    A stats provider implementation based on Twitter Science Stats library.
    @@ -124,12 +130,12 @@ <T extends Number>
    void     -PrometheusStatsLogger.registerGauge(String name, +CodahaleStatsLogger.registerGauge(String statName, Gauge<T> gauge)  <T extends Number>
    void     -CodahaleStatsLogger.registerGauge(String statName, +NullStatsLogger.registerGauge(String name, Gauge<T> gauge)  @@ -146,34 +152,48 @@ <T extends Number>
    void     -NullStatsLogger.registerGauge(String name, - Gauge<T> gauge)  +CodahaleStatsLogger.unregisterGauge(String statName, + Gauge<T> gauge)  <T extends Number>
    void     -PrometheusStatsLogger.unregisterGauge(String name, +NullStatsLogger.unregisterGauge(String name, Gauge<T> gauge)  <T extends Number>
    void     -CodahaleStatsLogger.unregisterGauge(String statName, - Gauge<T> gauge)  - - -<T extends Number>
    void     CachingStatsLogger.unregisterGauge(String name, Gauge<T> gauge)  - + <T extends Number>
    void     StatsLogger.unregisterGauge(String name, Gauge<T> gauge)
    Unregister given gauge from name name.
    + + +
    • +
  • + + +

    Uses of Gauge in org.apache.bookkeeper.stats.prometheus

    + + + + + + + + + + + - diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsData.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsData.html index b1e352b..81b7457 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsData.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsData.html @@ -89,18 +89,24 @@ + + + + - + - + - - - - + + + + - + +
    Methods in org.apache.bookkeeper.stats.prometheus with parameters of type Gauge 
    Modifier and TypeMethod and Description
    <T extends Number>
    void    		PrometheusStatsLogger.registerGauge(String name, + Gauge<T> gauge) 
    <T extends Number>
    void    		NullStatsLogger.unregisterGauge(String name, +PrometheusStatsLogger.unregisterGauge(String name, Gauge<T> gauge) 
    org.apache.bookkeeper.stats.prometheus +
    A stats provider implementation based on https://prometheus.io/.
    +
    org.apache.bookkeeper.stats.twitter.finagle
    A stats provider implemented based on finagle stats library.
    org.apache.bookkeeper.stats.twitter.ostrich
    A stats provider implemented based on Twitter Ostrich library.
    org.apache.bookkeeper.stats.twitter.science
    A stats provider implementation based on Twitter Science Stats library.
    @@ -137,21 +143,35 @@
    OpStatsDataPrometheusOpStatsLogger.toOpStatsData() 
    OpStatsData CodahaleOpStatsLogger.toOpStatsData()
    This function should go away soon (hopefully).
    OpStatsDataNullStatsLogger.NullOpStatsLogger.toOpStatsData() 
    OpStatsData OpStatsLogger.toOpStatsData() 
    +
    • +
  • + + +

    Uses of OpStatsData in org.apache.bookkeeper.stats.prometheus

    + + + + + + + + - +
    Methods in org.apache.bookkeeper.stats.prometheus that return OpStatsData 
    Modifier and TypeMethod and Description
    OpStatsDataNullStatsLogger.NullOpStatsLogger.toOpStatsData() PrometheusOpStatsLogger.toOpStatsData() 
    diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsLogger.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsLogger.html index 815cd44..91cacdc 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsLogger.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/OpStatsLogger.html @@ -95,18 +95,24 @@ +org.apache.bookkeeper.stats.prometheus + +
    A stats provider implementation based on https://prometheus.io/.
    + + + org.apache.bookkeeper.stats.twitter.finagle
    A stats provider implemented based on finagle stats library.
    - + org.apache.bookkeeper.stats.twitter.ostrich
    A stats provider implemented based on Twitter Ostrich library.
    - + org.apache.bookkeeper.stats.twitter.science
    A stats provider implementation based on Twitter Science Stats library.
    @@ -241,12 +247,6 @@
    A no-op OpStatsLogger.
    - -class  -PrometheusOpStatsLogger -
    A Prometheus based OpStatsLogger implementation.
    - - @@ -271,11 +271,11 @@ - + - + @@ -285,9 +285,38 @@ + +
    OpStatsLoggerPrometheusStatsLogger.getOpStatsLogger(String name) CodahaleStatsLogger.getOpStatsLogger(String statName) 
    OpStatsLoggerCodahaleStatsLogger.getOpStatsLogger(String statName) NullStatsLogger.getOpStatsLogger(String name) 
    OpStatsLoggerOpStatsLogger StatsLogger.getOpStatsLogger(String name) 
    +
    • +
  • + + +

    Uses of OpStatsLogger in org.apache.bookkeeper.stats.prometheus

    + + + + + + + + + + + + +
    Classes in org.apache.bookkeeper.stats.prometheus that implement OpStatsLogger 
    Modifier and TypeClass and Description
    class PrometheusOpStatsLogger +
    A Prometheus based OpStatsLogger implementation.
    +
    + + + + + + + - +
    Methods in org.apache.bookkeeper.stats.prometheus that return OpStatsLogger 
    Modifier and TypeMethod and Description
    OpStatsLoggerNullStatsLogger.getOpStatsLogger(String name) PrometheusStatsLogger.getOpStatsLogger(String name) 
    diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsLogger.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsLogger.html index 8efadad..8b602f8 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsLogger.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsLogger.html @@ -95,18 +95,24 @@ +org.apache.bookkeeper.stats.prometheus + +
    A stats provider implementation based on https://prometheus.io/.
    + + + org.apache.bookkeeper.stats.twitter.finagle
    A stats provider implemented based on finagle stats library.
    - + org.apache.bookkeeper.stats.twitter.ostrich
    A stats provider implemented based on Twitter Ostrich library.
    - + org.apache.bookkeeper.stats.twitter.science
    A stats provider implementation based on Twitter Science Stats library.
    @@ -129,13 +135,13 @@ -protected StatsLogger -RackawareEnsemblePlacementPolicyImpl.statsLogger  - - (package private) StatsLogger BookKeeper.Builder.statsLogger  + +protected StatsLogger +RackawareEnsemblePlacementPolicyImpl.statsLogger  + @@ -159,24 +165,24 @@ - - + - - + - - + - - + + StatsLogger statsLogger) +
    Initialize the policy.
    + - - + + StatsLogger statsLogger)  @@ -278,12 +284,6 @@
    A no-op StatsLogger.
    - - - -
    EnsemblePlacementPolicyDefaultEnsemblePlacementPolicy.initialize(RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger) 
    RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(RegionAwareEnsemblePlacementPolicyRegionAwareEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger) 
    RegionAwareEnsemblePlacementPolicyRegionAwareEnsemblePlacementPolicy.initialize(EnsemblePlacementPolicyDefaultEnsemblePlacementPolicy.initialize(Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, @@ -193,26 +199,26 @@
    protected RackawareEnsemblePlacementPolicyRackawareEnsemblePlacementPolicy.initialize(org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver, +protected RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, boolean isWeighted, int maxWeightMultiple, - StatsLogger statsLogger) 
    protected RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.initialize(org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver, +protected RackawareEnsemblePlacementPolicyRackawareEnsemblePlacementPolicy.initialize(org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, boolean isWeighted, int maxWeightMultiple, - StatsLogger statsLogger) -
    Initialize the policy.
    -
    BookKeeper.Builder
    class PrometheusStatsLogger -
    A Prometheus based StatsLogger implementation.
    -
    @@ -329,19 +329,11 @@ - - - - - - - - - + @@ -351,7 +343,7 @@ - + @@ -359,17 +351,17 @@ - + - + - +
    StatsLoggerPrometheusMetricsProvider.getStatsLogger(String scope) 
    StatsLogger CodahaleMetricsProvider.getStatsLogger(String name) 
    StatsLoggerCachingStatsProvider.getStatsLogger(String scope) 
    StatsLoggerNullStatsProvider.getStatsLogger(String scope) CachingStatsProvider.getStatsLogger(String scope) 
    StatsLogger
    StatsLoggerPrometheusStatsLogger.scope(String name) NullStatsProvider.getStatsLogger(String scope) 
    StatsLogger
    StatsLoggerCachingStatsLogger.scope(String name) NullStatsLogger.scope(String name) 
    StatsLoggerStatsLogger.scope(String name) -
    Provide the stats logger under scope name.
    -    		CachingStatsLogger.scope(String name) 
    StatsLoggerNullStatsLogger.scope(String name) StatsLogger.scope(String name) +
    Provide the stats logger under scope name.
    +
    @@ -382,12 +374,12 @@ void -PrometheusStatsLogger.removeScope(String name, +CodahaleStatsLogger.removeScope(String name, StatsLogger statsLogger)  void -CodahaleStatsLogger.removeScope(String name, +NullStatsLogger.removeScope(String name, StatsLogger statsLogger)  @@ -402,11 +394,6 @@
    Remove the given statsLogger for scope name.
    - -void -NullStatsLogger.removeScope(String name, - StatsLogger statsLogger)  - @@ -430,6 +417,57 @@
    • +
  • + + +

    Uses of StatsLogger in org.apache.bookkeeper.stats.prometheus

    + + + + + + + + + + + + +
    Classes in org.apache.bookkeeper.stats.prometheus that implement StatsLogger 
    Modifier and TypeClass and Description
    class PrometheusStatsLogger +
    A Prometheus based StatsLogger implementation.
    +
    + + + + + + + + + + + + + + + + +
    Methods in org.apache.bookkeeper.stats.prometheus that return StatsLogger 
    Modifier and TypeMethod and Description
    StatsLoggerPrometheusMetricsProvider.getStatsLogger(String scope) 
    StatsLoggerPrometheusStatsLogger.scope(String name) 
    + + + + + + + + + + + + +
    Methods in org.apache.bookkeeper.stats.prometheus with parameters of type StatsLogger 
    Modifier and TypeMethod and Description
    voidPrometheusStatsLogger.removeScope(String name, + StatsLogger statsLogger) 
    +
  • diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsProvider.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsProvider.html index beddecc..5f9ac2f 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsProvider.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/class-use/StatsProvider.html @@ -93,18 +93,24 @@ +org.apache.bookkeeper.stats.prometheus + +
    A stats provider implementation based on https://prometheus.io/.
    + + + org.apache.bookkeeper.stats.twitter.finagle
    A stats provider implemented based on finagle stats library.
    - + org.apache.bookkeeper.stats.twitter.ostrich
    A stats provider implemented based on Twitter Ostrich library.
    - + org.apache.bookkeeper.stats.twitter.science
    A stats provider implementation based on Twitter Science Stats library.
    @@ -179,12 +185,6 @@
    A no-op stats provider implementation.
    - -class  -PrometheusMetricsProvider -
    A Prometheus based StatsProvider implementation.
    - - @@ -229,6 +229,26 @@
    • +
  • + + +

    Uses of StatsProvider in org.apache.bookkeeper.stats.prometheus

    + + + + + + + + + + + + +
    Classes in org.apache.bookkeeper.stats.prometheus that implement StatsProvider 
    Modifier and TypeClass and Description
    class PrometheusMetricsProvider +
    A Prometheus based StatsProvider implementation.
    +
    +
  • diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-frame.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-frame.html index b4afcd8..c617cf6 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-frame.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-frame.html @@ -32,11 +32,6 @@
  • NullStatsLogger.NullOpStatsLogger
  • NullStatsProvider
  • OpStatsData
    • -
  • PrometheusCounter
    • -
  • PrometheusMetricsProvider
    • -
  • PrometheusOpStatsLogger
    • -
  • PrometheusStatsLogger
    • -
  • PrometheusUtil
  • Stats
    • diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-summary.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-summary.html index 20e39dc..da4a6b7 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-summary.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-summary.html @@ -44,7 +44,7 @@
    • Frames
      • @@ -193,36 +193,6 @@ -PrometheusCounter - -
      A Counter implementation based on Prometheus metrics library.
      - - - -PrometheusMetricsProvider - -
      A Prometheus based StatsProvider implementation.
      - - - -PrometheusOpStatsLogger - -
      A Prometheus based OpStatsLogger implementation.
      - - - -PrometheusStatsLogger - -
      A Prometheus based StatsLogger implementation.
      - - - -PrometheusUtil - -
      Container for Prometheus utility methods.
      - - - Stats
      An umbrella class for loading stats provider.
      @@ -260,7 +230,7 @@
      • Frames
        • diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-tree.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-tree.html index 4a8bd5d..3c72bf4 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-tree.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-tree.html @@ -44,7 +44,7 @@
        @@ -132,7 +127,7 @@
        • Frames
          • diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-use.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-use.html index d1e8563..688a9cb 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-use.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/package-use.html @@ -99,18 +99,24 @@ +org.apache.bookkeeper.stats.prometheus + +
          A stats provider implementation based on https://prometheus.io/.
          + + + org.apache.bookkeeper.stats.twitter.finagle
          A stats provider implemented based on finagle stats library.
          - + org.apache.bookkeeper.stats.twitter.ostrich
          A stats provider implemented based on Twitter Ostrich library.
          - + org.apache.bookkeeper.stats.twitter.science
          A stats provider implementation based on Twitter Science Stats library.
          @@ -222,6 +228,49 @@ +
        • + + + + + + + + + + + + + + + + + + + + + + + + + + + +
          Classes in org.apache.bookkeeper.stats used by org.apache.bookkeeper.stats.prometheus 
          Class and Description
          Counter +
          Simple stats that require only increment and decrement + functions on a Long.
          +
          Gauge +
          A guage is a value that has only one value at a specific point in time.
          +
          OpStatsData +
          This class provides a read view of operation specific stats.
          +
          OpStatsLogger +
          This interface handles logging of statistics related to each operation.
          +
          StatsLogger +
          A simple interface that exposes just 2 useful methods.
          +
          StatsProvider +
          Provider to provide stats logger for different scopes.
          +
          +
        • diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusCounter.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusCounter.html new file mode 100644 index 0000000..1e34c23 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusCounter.html @@ -0,0 +1,372 @@ + + + + + + +PrometheusCounter (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          +
          +
            +
          • Summary: 
            • +
          • Nested | 
            • +
          • Field | 
            • +
          • Constr | 
            • +
          • Method
            • +
          + +
          + + +
          + + +
          +
          org.apache.bookkeeper.stats.prometheus
          +

          Class PrometheusCounter

          +
          +
          +
            +
          • java.lang.Object
            • +
          • +
              +
            • org.apache.bookkeeper.stats.prometheus.PrometheusCounter
              • +
            +
            • +
          +
          +
            +
          • +
            +
            All Implemented Interfaces:
            +
            Counter
            +
            +
            +
            +
            public class PrometheusCounter
+extends Object
+implements Counter
            +
            A Counter implementation based on Prometheus metrics library.
            +
            • +
          +
          +
          +
            +
          • + +
              +
            • + + +

              Constructor Summary

              + + + + + + + + +
              Constructors 
              Constructor and Description
              PrometheusCounter(io.prometheus.client.CollectorRegistry registry, + String name) 
              +
              • +
            + +
              +
            • + + +

              Method Summary

              + + + + + + + + + + + + + + + + + + + + + + + + + + +
              All Methods Instance Methods Concrete Methods 
              Modifier and TypeMethod and Description
              voidadd(long delta) +
              Add delta to the value associated with this stat.
              +
              voidclear() +
              Clear this stat.
              +
              voiddec() +
              Decrement the value associated with this stat.
              +
              Longget() +
              Get the value associated with this stat.
              +
              voidinc() +
              Increment the value associated with this stat.
              +
              +
                +
              • + + +

                Methods inherited from class java.lang.Object

                +clone, equals, finalize, +
                  +
                • + +
                    +
                  • + + +

                    Constructor Detail

                    + + + +
                      +
                    • +

                      PrometheusCounter

                      +
                      public PrometheusCounter(io.prometheus.client.CollectorRegistry registry,
+                         String name)
                      +
                      • +
                    +
                    • +
                  + +
                    +
                  • + + +

                    Method Detail

                    + + + +
                      +
                    • +

                      clear

                      +
                      public void clear()
                      +
                      Description copied from interface: Counter
                      +
                      Clear this stat.
                      +
                      +
                      Specified by:
                      +
                      clear in interface Counter
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      inc

                      +
                      public void inc()
                      +
                      Description copied from interface: Counter
                      +
                      Increment the value associated with this stat.
                      +
                      +
                      Specified by:
                      +
                      inc in interface Counter
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      dec

                      +
                      public void dec()
                      +
                      Description copied from interface: Counter
                      +
                      Decrement the value associated with this stat.
                      +
                      +
                      Specified by:
                      +
                      dec in interface Counter
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      add

                      +
                      public void add(long delta)
                      +
                      Description copied from interface: Counter
                      +
                      Add delta to the value associated with this stat.
                      +
                      +
                      Specified by:
                      +
                      add in interface Counter
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      get

                      +
                      public Long get()
                      +
                      Description copied from interface: Counter
                      +
                      Get the value associated with this stat.
                      +
                      +
                      Specified by:
                      +
                      get in interface Counter
                      +
                      +
                      • +
                    +
                    • +
                  +
                  • +
                +
          +
          + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          +
          +
            +
          • Summary: 
            • +
          • Nested | 
            • +
          • Field | 
            • +
          • Constr | 
            • +
          • Method
            • +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusMetricsProvider.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusMetricsProvider.html new file mode 100644 index 0000000..4cba373 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusMetricsProvider.html @@ -0,0 +1,334 @@ + + + + + + +PrometheusMetricsProvider (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          +
          +
            +
          • Summary: 
            • +
          • Nested | 
            • +
          • Field | 
            • +
          • Constr | 
            • +
          • Method
            • +
          + +
          + + +
          + + +
          +
          org.apache.bookkeeper.stats.prometheus
          +

          Class PrometheusMetricsProvider

          +
          +
          +
            +
          • java.lang.Object
            • +
          • +
              +
            • org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
              • +
            +
            • +
          +
          + +
          +
          +
            +
          • + + + +
              +
            • + + +

              Method Summary

              + + + + + + + + + + + + + + + + + + +
              All Methods Instance Methods Concrete Methods 
              Modifier and TypeMethod and Description
              StatsLoggergetStatsLogger(String scope) +
              Return the stats logger to a given scope.
              +
              voidstart(org.apache.commons.configuration.Configuration conf) +
              Intialize the stats provider by loading the given configuration conf.
              +
              voidstop() +
              Close the stats provider.
              +
              +
                +
              • + + +

                Methods inherited from class java.lang.Object

                +clone, equals, finalize, +
                  +
                • + +
                    +
                  • + + +

                    Constructor Detail

                    + + + +
                      +
                    • +

                      PrometheusMetricsProvider

                      +
                      public PrometheusMetricsProvider()
                      +
                      • +
                    +
                    • +
                  + +
                    +
                  • + + +

                    Method Detail

                    + + + +
                      +
                    • +

                      start

                      +
                      public void start(org.apache.commons.configuration.Configuration conf)
                      +
                      Description copied from interface: StatsProvider
                      +
                      Intialize the stats provider by loading the given configuration conf.
                      +
                      +
                      Specified by:
                      +
                      start in interface StatsProvider
                      +
                      Parameters:
                      +
                      conf - Configuration to configure the stats provider.
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      stop

                      +
                      public void stop()
                      +
                      Description copied from interface: StatsProvider
                      +
                      Close the stats provider.
                      +
                      +
                      Specified by:
                      +
                      stop in interface StatsProvider
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      getStatsLogger

                      +
                      public StatsLogger getStatsLogger(String scope)
                      +
                      Description copied from interface: StatsProvider
                      +
                      Return the stats logger to a given scope.
                      +
                      +
                      Specified by:
                      +
                      getStatsLogger in interface StatsProvider
                      +
                      Parameters:
                      +
                      scope - Scope for the given stats
                      +
                      Returns:
                      +
                      stats logger for the given scope
                      +
                      +
                      • +
                    +
                    • +
                  +
                  • +
                +
          +
          + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          +
          +
            +
          • Summary: 
            • +
          • Nested | 
            • +
          • Field | 
            • +
          • Constr | 
            • +
          • Method
            • +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusOpStatsLogger.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusOpStatsLogger.html new file mode 100644 index 0000000..aa08387 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusOpStatsLogger.html @@ -0,0 +1,402 @@ + + + + + + +PrometheusOpStatsLogger (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          +
          +
            +
          • Summary: 
            • +
          • Nested | 
            • +
          • Field | 
            • +
          • Constr | 
            • +
          • Method
            • +
          + +
          + + +
          + + +
          +
          org.apache.bookkeeper.stats.prometheus
          +

          Class PrometheusOpStatsLogger

          +
          +
          +
            +
          • java.lang.Object
            • +
          • +
              +
            • org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger
              • +
            +
            • +
          +
          + +
          +
          +
            +
          • + +
              +
            • + + +

              Constructor Summary

              + + + + + + + + +
              Constructors 
              Constructor and Description
              PrometheusOpStatsLogger(io.prometheus.client.CollectorRegistry registry, + String name) 
              +
              • +
            + +
              +
            • + + +

              Method Summary

              + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
              All Methods Instance Methods Concrete Methods 
              Modifier and TypeMethod and Description
              voidclear() +
              Clear stats for this operation.
              +
              voidregisterFailedEvent(long eventLatency, + TimeUnit unit) +
              Increment the failed op counter with the given eventLatency.
              +
              voidregisterFailedValue(long value) +
              An operation with the given value failed.
              +
              voidregisterSuccessfulEvent(long eventLatency, + TimeUnit unit) +
              An operation succeeded with the given eventLatency.
              +
              voidregisterSuccessfulValue(long value) +
              An operation with the given value succeeded.
              +
              OpStatsDatatoOpStatsData() 
              +
                +
              • + + +

                Methods inherited from class java.lang.Object

                +clone, equals, finalize, +
                  +
                • + +
                    +
                  • + + +

                    Constructor Detail

                    + + + +
                      +
                    • +

                      PrometheusOpStatsLogger

                      +
                      public PrometheusOpStatsLogger(io.prometheus.client.CollectorRegistry registry,
+                               String name)
                      +
                      • +
                    +
                    • +
                  + +
                    +
                  • + + +

                    Method Detail

                    + + + +
                      +
                    • +

                      registerSuccessfulEvent

                      +
                      public void registerSuccessfulEvent(long eventLatency,
+                                    TimeUnit unit)
                      +
                      Description copied from interface: OpStatsLogger
                      +
                      An operation succeeded with the given eventLatency. Update + stats to reflect the same
                      +
                      +
                      Specified by:
                      +
                      registerSuccessfulEvent in interface OpStatsLogger
                      +
                      Parameters:
                      +
                      eventLatency - The event latency
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      registerFailedEvent

                      +
                      public void registerFailedEvent(long eventLatency,
+                                TimeUnit unit)
                      +
                      Description copied from interface: OpStatsLogger
                      +
                      Increment the failed op counter with the given eventLatency.
                      +
                      +
                      Specified by:
                      +
                      registerFailedEvent in interface OpStatsLogger
                      +
                      Parameters:
                      +
                      eventLatency - The event latency
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      registerSuccessfulValue

                      +
                      public void registerSuccessfulValue(long value)
                      +
                      Description copied from interface: OpStatsLogger
                      +
                      An operation with the given value succeeded.
                      +
                      +
                      Specified by:
                      +
                      registerSuccessfulValue in interface OpStatsLogger
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      registerFailedValue

                      +
                      public void registerFailedValue(long value)
                      +
                      Description copied from interface: OpStatsLogger
                      +
                      An operation with the given value failed.
                      +
                      +
                      Specified by:
                      +
                      registerFailedValue in interface OpStatsLogger
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      toOpStatsData

                      +
                      public OpStatsData toOpStatsData()
                      +
                      +
                      Specified by:
                      +
                      toOpStatsData in interface OpStatsLogger
                      +
                      Returns:
                      +
                      Returns an OpStatsData object with necessary values. We need this function + to support JMX exports. This should be deprecated sometime in the near future. + populated.
                      +
                      +
                      • +
                    + + + +
                      +
                    • +

                      clear

                      +
                      public void clear()
                      +
                      Description copied from interface: OpStatsLogger
                      +
                      Clear stats for this operation.
                      +
                      +
                      Specified by:
                      +
                      clear in interface OpStatsLogger
                      +
                      +
                      • +
                    +
                    • +
                  +
                  • +
                +
          +
          + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          +
          +
            +
          • Summary: 
            • +
          • Nested | 
            • +
          • Field | 
            • +
          • Constr | 
            • +
          • Method
            • +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusStatsLogger.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusStatsLogger.html new file mode 100644 index 0000000..9821c52 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusStatsLogger.html @@ -0,0 +1,413 @@ + + + + + + +PrometheusStatsLogger (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          +
          +
            +
          • Summary: 
            • +
          • Nested | 
            • +
          • Field | 
            • +
          • Constr | 
            • +
          • Method
            • +
          + +
          + + +
          + + +
          +
          org.apache.bookkeeper.stats.prometheus
          +

          Class PrometheusStatsLogger

          +
          +
          +
            +
          • java.lang.Object
            • +
          • +
              +
            • org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
              • +
            +
            • +
          +
          + +
          +
          +
          +
          + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          +
          +
            +
          • Summary: 
            • +
          • Nested | 
            • +
          • Field | 
            • +
          • Constr | 
            • +
          • Method
            • +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/Stats.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusUtil.html similarity index 56% copy from content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/Stats.html copy to content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusUtil.html index 039c270..dd7fb0b 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/Stats.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/PrometheusUtil.html @@ -4,21 +4,21 @@ -Stats (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) - - +PrometheusUtil (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +
          +

          Uses of Class
          org.apache.bookkeeper.stats.prometheus.PrometheusCounter

          +
          +
          No usage of org.apache.bookkeeper.stats.prometheus.PrometheusCounter
          + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusMetricsProvider.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusMetricsProvider.html new file mode 100644 index 0000000..f32e336 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusMetricsProvider.html @@ -0,0 +1,125 @@ + + + + + + +Uses of Class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +
          +

          Uses of Class
          org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

          +
          +
          No usage of org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
          + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusOpStatsLogger.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusOpStatsLogger.html new file mode 100644 index 0000000..94c4c54 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusOpStatsLogger.html @@ -0,0 +1,125 @@ + + + + + + +Uses of Class org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +
          +

          Uses of Class
          org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger

          +
          +
          No usage of org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger
          + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusStatsLogger.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusStatsLogger.html new file mode 100644 index 0000000..47b3df6 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusStatsLogger.html @@ -0,0 +1,125 @@ + + + + + + +Uses of Class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +
          +

          Uses of Class
          org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger

          +
          +
          No usage of org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
          + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusUtil.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusUtil.html new file mode 100644 index 0000000..6f66355 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/class-use/PrometheusUtil.html @@ -0,0 +1,125 @@ + + + + + + +Uses of Class org.apache.bookkeeper.stats.prometheus.PrometheusUtil (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +
          +

          Uses of Class
          org.apache.bookkeeper.stats.prometheus.PrometheusUtil

          +
          +
          No usage of org.apache.bookkeeper.stats.prometheus.PrometheusUtil
          + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-frame.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-frame.html new file mode 100644 index 0000000..9d51f6b --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-frame.html @@ -0,0 +1,24 @@ + + + + + + +org.apache.bookkeeper.stats.prometheus (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + +

          org.apache.bookkeeper.stats.prometheus

          +
          +

          Classes

          + +
          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-summary.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-summary.html new file mode 100644 index 0000000..d693517 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-summary.html @@ -0,0 +1,178 @@ + + + + + + +org.apache.bookkeeper.stats.prometheus (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          + + +
          + +
          +

          Package org.apache.bookkeeper.stats.prometheus

          +
          +
          A stats provider implementation based on https://prometheus.io/.
          +
          +

          See: Description

          +
          +
          + + + + +

          Package org.apache.bookkeeper.stats.prometheus Description

          +
          A stats provider implementation based on https://prometheus.io/.
          +
          + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-tree.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-tree.html new file mode 100644 index 0000000..3a831e1 --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-tree.html @@ -0,0 +1,142 @@ + + + + + + +org.apache.bookkeeper.stats.prometheus Class Hierarchy (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          + + +
          + +
          +

          Hierarchy For Package org.apache.bookkeeper.stats.prometheus

          +Package Hierarchies: + +
          +
          +

          Class Hierarchy

          + +
          + +
          + + +
          Skip navigation links
          + + + + +
          +
          + + + +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-use.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-use.html new file mode 100644 index 0000000..2ac7e8e --- /dev/null +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/prometheus/package-use.html @@ -0,0 +1,125 @@ + + + + + + +Uses of Package org.apache.bookkeeper.stats.prometheus (Apache BookKeeper :: Parent 4.6.0-SNAPSHOT API) + + + + + + + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +
          +

          Uses of Package
          org.apache.bookkeeper.stats.prometheus

          +
          +
          No usage of org.apache.bookkeeper.stats.prometheus
          + +
          + + +
          Skip navigation links
          + + + + +
          +
          +
            +
          • Prev
            • +
          • Next
            • +
          + + +
          + +
          + + +
          + +

          Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.

          + + diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/twitter/finagle/package-summary.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/twitter/finagle/package-summary.html index 1d4ef3f..0248af1 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/twitter/finagle/package-summary.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/twitter/finagle/package-summary.html @@ -43,7 +43,7 @@
          @@ -142,7 +142,7 @@
          diff --git a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/twitter/finagle/package-tree.html b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/twitter/finagle/package-tree.html index 5ecd52b..b057654 100644 --- a/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/twitter/finagle/package-tree.html +++ b/content/docs/latest/api/javadoc/org/apache/bookkeeper/stats/twitter/finagle/package-tree.html @@ -43,7 +43,7 @@
          @@ -110,7 +110,7 @@
        +
        + + + + + + + + + + + + +
        Other Packages 
        PackageDescription
        org.apache.bookkeeper.stats.prometheus +
        A stats provider implementation based on https://prometheus.io/.
        +
        +
        diff --git a/content/docs/latest/api/javadoc/overview-tree.html b/content/docs/latest/api/javadoc/overview-tree.html index d39bfc4..1e6905b 100644 --- a/content/docs/latest/api/javadoc/overview-tree.html +++ b/content/docs/latest/api/javadoc/overview-tree.html @@ -78,6 +78,7 @@
      • org.apache.bookkeeper.conf,
      • org.apache.bookkeeper.feature,
      • org.apache.bookkeeper.stats,
        • +
      • org.apache.bookkeeper.stats.prometheus,
      • org.apache.bookkeeper.stats.twitter.finagle,
      • org.apache.bookkeeper.stats.twitter.ostrich,
      • org.apache.bookkeeper.stats.twitter.science
        • @@ -227,11 +228,11 @@
    • org.apache.bookkeeper.client.PendingWriteLacOp (implements org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.WriteLacCallback)
      • -
    • org.apache.bookkeeper.stats.PrometheusCounter (implements org.apache.bookkeeper.stats.Counter)
      • -
    • org.apache.bookkeeper.stats.PrometheusMetricsProvider (implements org.apache.bookkeeper.stats.StatsProvider)
      • -
    • org.apache.bookkeeper.stats.PrometheusOpStatsLogger (implements org.apache.bookkeeper.stats.OpStatsLogger)
      • -
    • org.apache.bookkeeper.stats.PrometheusStatsLogger (implements org.apache.bookkeeper.stats.StatsLogger)
      • -
    • org.apache.bookkeeper.stats.PrometheusUtil
      • +
    • org.apache.bookkeeper.stats.prometheus.PrometheusCounter (implements org.apache.bookkeeper.stats.Counter)
      • +
    • org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider (implements org.apache.bookkeeper.stats.StatsProvider)
      • +
    • org.apache.bookkeeper.stats.prometheus.PrometheusOpStatsLogger (implements org.apache.bookkeeper.stats.OpStatsLogger)
      • +
    • org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger (implements org.apache.bookkeeper.stats.StatsLogger)
      • +
    • org.apache.bookkeeper.stats.prometheus.PrometheusUtil
    • org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl.DefaultResolver (implements org.apache.bookkeeper.net.DNSToSwitchMapping)
    • org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl.DNSResolverDecorator (implements org.apache.bookkeeper.net.DNSToSwitchMapping)
    • org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp (implements org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryCallback, org.apache.bookkeeper.client.SpeculativeRequestExecut [...] @@ -375,8 +376,8 @@
    diff --git a/content/docs/latest/api/javadoc/package-list b/content/docs/latest/api/javadoc/package-list index 0e592c4..96268ce 100644 --- a/content/docs/latest/api/javadoc/package-list +++ b/content/docs/latest/api/javadoc/package-list @@ -3,6 +3,7 @@ org.apache.bookkeeper.common.annotation org.apache.bookkeeper.conf org.apache.bookkeeper.feature org.apache.bookkeeper.stats +org.apache.bookkeeper.stats.prometheus org.apache.bookkeeper.stats.twitter.finagle org.apache.bookkeeper.stats.twitter.ostrich org.apache.bookkeeper.stats.twitter.science -- To stop receiving notification emails like this one, please contact ['"commits@bookkeeper.apache.org" '].