Uses of Interface
org.apache.bookkeeper.stats.OpStatsLogger

Packages that use OpStatsLogger

Package	Description
org.apache.bookkeeper.bookie	Provides a Bookie server that stores entries for clients.
org.apache.bookkeeper.bookie.stats	Package of the classes for defining bookie stats.
org.apache.bookkeeper.bookie.storage.directentrylogger	Support for bookie entry logs using Direct IO.
org.apache.bookkeeper.bookie.storage.ldb	Classes related to DB based ledger storage.
org.apache.bookkeeper.client	BookKeeper Client.
org.apache.bookkeeper.client.impl	BookKeeper Client implementation package.
org.apache.bookkeeper.common.concurrent	Utility classes commonly useful in concurrent programming.
org.apache.bookkeeper.common.stats	Stats Related Utils.
org.apache.bookkeeper.common.util	defines the utilities for allocator used across the project.
org.apache.bookkeeper.proto	Classes related to the Bookkeeper protocol.
org.apache.bookkeeper.replication	Classes for replicating Bookkeeper data.
org.apache.bookkeeper.stats	A lightweight stats library used for exporting bookkeeper stats.
org.apache.bookkeeper.stats.codahale	A lightweight stats library implementation based on Codahale metrics library.
org.apache.bookkeeper.stats.otel	A stats provider implementation based on OpenTelemetry.
org.apache.bookkeeper.stats.prometheus	A stats provider implementation based on {@link https://prometheus.io/}.
org.apache.bookkeeper.zookeeper	A simple retryable zookeeper wrapper provided in bookkeeper.

Uses of OpStatsLogger in org.apache.bookkeeper.bookie

Fields in org.apache.bookkeeper.bookie declared as OpStatsLogger

Modifier and Type	Field	Description
(package private) OpStatsLogger	Journal.QueueEntry.journalAddEntryStats

Methods in org.apache.bookkeeper.bookie with parameters of type OpStatsLogger

Modifier and Type	Method	Description
(package private) static Journal.QueueEntry	Journal.QueueEntry.create(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, long ledgerId, long entryId, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, long enqueueTime, OpStatsLogger journalAddEntryStats, Counter callbackTime)

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

Methods in org.apache.bookkeeper.bookie.stats that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	BookieStats.getAddBytesStats()
OpStatsLogger	BookieStats.getAddEntryStats()
OpStatsLogger	GarbageCollectorStats.getCompactRuntime()
OpStatsLogger	GarbageCollectorStats.getExtractMetaRuntime()
OpStatsLogger	JournalStats.getForceWriteBatchBytesStats()
OpStatsLogger	JournalStats.getForceWriteBatchEntriesStats()
OpStatsLogger	JournalStats.getForceWriteGroupingCountStats()
OpStatsLogger	JournalStats.getFwEnqueueTimeStats()
OpStatsLogger	GarbageCollectorStats.getGcLedgerRuntime()
OpStatsLogger	GarbageCollectorStats.getGcThreadRuntime()
OpStatsLogger	EntryMemTableStats.getGetEntryStats()
OpStatsLogger	BookieStats.getGetListOfEntriesOfLedgerStats()
OpStatsLogger	JournalStats.getJournalAddEntryStats()
OpStatsLogger	JournalStats.getJournalCreationStats()
OpStatsLogger	JournalStats.getJournalFlushStats()
OpStatsLogger	JournalStats.getJournalForceLedgerStats()
OpStatsLogger	JournalStats.getJournalProcessTimeStats()
OpStatsLogger	JournalStats.getJournalQueueStats()
OpStatsLogger	JournalStats.getJournalSyncStats()
OpStatsLogger	EntryMemTableStats.getPutEntryStats()
OpStatsLogger	BookieStats.getReadBytesStats()
OpStatsLogger	BookieStats.getReadEntryStats()
OpStatsLogger	BookieStats.getRecoveryAddEntryStats()
OpStatsLogger	EntryMemTableStats.getSnapshotStats()
OpStatsLogger	EntryMemTableStats.getThrottlingStats()

Uses of OpStatsLogger in org.apache.bookkeeper.bookie.storage.directentrylogger

Methods in org.apache.bookkeeper.bookie.storage.directentrylogger that return OpStatsLogger

Modifier and Type	Method	Description
(package private) OpStatsLogger	DirectEntryLoggerStats.getAddEntryStats()
(package private) OpStatsLogger	DirectEntryLoggerStats.getFlushStats()
(package private) OpStatsLogger	DirectEntryLoggerStats.getReadBlockStats()
(package private) OpStatsLogger	DirectEntryLoggerStats.getReadEntryStats()
(package private) OpStatsLogger	DirectEntryLoggerStats.getWriterFlushStats()

Methods in org.apache.bookkeeper.bookie.storage.directentrylogger with parameters of type OpStatsLogger

Modifier and Type	Method	Description
(package private) static CompactionEntryLog	DirectCompactionEntryLog.recoverLog(int srcLogId, int dstLogId, File ledgerDir, int readBufferSize, int maxSaneEntrySize, NativeIO nativeIO, io.netty.buffer.ByteBufAllocator allocator, OpStatsLogger readBlockStats, Slogger slog)

Constructors in org.apache.bookkeeper.bookie.storage.directentrylogger with parameters of type OpStatsLogger

Modifier	Constructor	Description
(package private)	DirectReader(int logId, String filename, io.netty.buffer.ByteBufAllocator allocator, NativeIO nativeIO, int bufferSize, int maxSaneEntrySize, OpStatsLogger readBlockStats)

Uses of OpStatsLogger in org.apache.bookkeeper.bookie.storage.ldb

Methods in org.apache.bookkeeper.bookie.storage.ldb that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	DbLedgerStorageStats.getAddEntryStats()
OpStatsLogger	DbLedgerStorageStats.getFlushEntryLogStats()
OpStatsLogger	DbLedgerStorageStats.getFlushLedgerIndexStats()
OpStatsLogger	DbLedgerStorageStats.getFlushLocationIndexStats()
OpStatsLogger	DbLedgerStorageStats.getFlushSizeStats()
OpStatsLogger	DbLedgerStorageStats.getFlushStats()
OpStatsLogger	EntryLocationIndexStats.getGetLastEntryInLedgerStats()
OpStatsLogger	EntryLocationIndexStats.getLookupEntryLocationStats()
OpStatsLogger	DbLedgerStorageStats.getReadAheadBatchCountStats()
OpStatsLogger	DbLedgerStorageStats.getReadAheadBatchSizeStats()
OpStatsLogger	DbLedgerStorageStats.getReadEntryStats()
OpStatsLogger	DbLedgerStorageStats.getThrottledWriteStats()

Uses of OpStatsLogger in org.apache.bookkeeper.client

Fields in org.apache.bookkeeper.client declared as OpStatsLogger

Modifier and Type	Field	Description
protected OpStatsLogger	TopologyAwareEnsemblePlacementPolicy.bookiesJoinedCounter
protected OpStatsLogger	TopologyAwareEnsemblePlacementPolicy.bookiesLeftCounter
(package private) final OpStatsLogger	LedgerCreateOp.createOpLogger
(package private) final OpStatsLogger	LedgerDeleteOp.deleteOpLogger
(package private) final OpStatsLogger	LedgerOpenOp.openOpLogger
protected OpStatsLogger	RackawareEnsemblePlacementPolicyImpl.readReorderedCounter

Methods in org.apache.bookkeeper.client that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	BookKeeperClientStats.getAddOpLogger()
OpStatsLogger	BookKeeperClientStats.getClientChannelWriteWaitLogger()
OpStatsLogger	BookKeeperClientStats.getCreateOpLogger()
OpStatsLogger	BookKeeperClientStats.getDeleteOpLogger()
OpStatsLogger	BookKeeperClientStats.getForceOpLogger()
OpStatsLogger	BookKeeperClientStats.getOpenOpLogger()
OpStatsLogger	BookKeeperClientStats.getReadLacAndEntryOpLogger()
OpStatsLogger	BookKeeperClientStats.getReadLacAndEntryRespLogger()
OpStatsLogger	BookKeeperClientStats.getReadLacOpLogger()
OpStatsLogger	BookKeeperClientStats.getReadOpLogger()
OpStatsLogger	BookKeeperClientStats.getRecoverAddCountLogger()
OpStatsLogger	BookKeeperClientStats.getRecoverOpLogger()
OpStatsLogger	BookKeeperClientStats.getRecoverReadCountLogger()
OpStatsLogger	BookKeeperClientStats.getWriteDelayedDueToNotEnoughFaultDomainsLatency()
OpStatsLogger	BookKeeperClientStats.getWriteLacOpLogger()

Uses of OpStatsLogger in org.apache.bookkeeper.client.impl

Methods in org.apache.bookkeeper.client.impl that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	BookKeeperClientStatsImpl.getAddOpLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getClientChannelWriteWaitLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getCreateOpLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getDeleteOpLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getForceOpLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getOpenOpLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getReadLacAndEntryOpLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getReadLacAndEntryRespLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getReadLacOpLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getReadOpLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getRecoverAddCountLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getRecoverOpLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getRecoverReadCountLogger()
OpStatsLogger	BookKeeperClientStatsImpl.getWriteDelayedDueToNotEnoughFaultDomainsLatency()
OpStatsLogger	BookKeeperClientStatsImpl.getWriteLacOpLogger()

Uses of OpStatsLogger in org.apache.bookkeeper.common.concurrent

Methods in org.apache.bookkeeper.common.concurrent with parameters of type OpStatsLogger

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	FutureUtils.stats(CompletableFuture<T> result, OpStatsLogger opStatsLogger, com.google.common.base.Stopwatch stopwatch)	Add a event listener over result for collecting the operation stats.

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

Methods in org.apache.bookkeeper.common.stats that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	BroadCastStatsLogger.Two.getOpStatsLogger(String statName)
OpStatsLogger	BroadCastStatsLogger.Two.getThreadScopedOpStatsLogger(String name)	Thread-scoped stats not currently supported.

Constructors in org.apache.bookkeeper.common.stats with parameters of type OpStatsLogger

Modifier	Constructor	Description
	OpStatsListener(OpStatsLogger opStatsLogger)
	OpStatsListener(OpStatsLogger opStatsLogger, com.google.common.base.Stopwatch stopwatch)

Uses of OpStatsLogger in org.apache.bookkeeper.common.util

Fields in org.apache.bookkeeper.common.util declared as OpStatsLogger

Modifier and Type	Field	Description
(package private) final OpStatsLogger	OrderedExecutor.taskExecutionStats
(package private) final OpStatsLogger	OrderedExecutor.taskPendingStats

Uses of OpStatsLogger in org.apache.bookkeeper.proto

Fields in org.apache.bookkeeper.proto declared as OpStatsLogger

Modifier and Type	Field	Description
(package private) final OpStatsLogger	RequestStats.addEntryBlockedStats
protected final OpStatsLogger	PerChannelBookieClient.addEntryOpLogger
protected final OpStatsLogger	PerChannelBookieClient.addTimeoutOpLogger
(package private) final OpStatsLogger	RequestStats.channelWriteStats
(package private) final OpStatsLogger	RequestStats.fenceReadEntryStats
(package private) final OpStatsLogger	RequestStats.fenceReadRequestStats
(package private) final OpStatsLogger	RequestStats.fenceReadWaitStats
protected final OpStatsLogger	PerChannelBookieClient.forceLedgerOpLogger
(package private) final OpStatsLogger	RequestStats.forceLedgerRequestStats
(package private) final OpStatsLogger	RequestStats.forceLedgerStats
protected final OpStatsLogger	PerChannelBookieClient.forceLedgerTimeoutOpLogger
protected final OpStatsLogger	PerChannelBookieClient.getBookieInfoOpLogger
(package private) final OpStatsLogger	RequestStats.getBookieInfoRequestStats
(package private) final OpStatsLogger	RequestStats.getBookieInfoStats
protected final OpStatsLogger	PerChannelBookieClient.getBookieInfoTimeoutOpLogger
protected final OpStatsLogger	PerChannelBookieClient.getListOfEntriesOfLedgerCompletionOpLogger
protected final OpStatsLogger	PerChannelBookieClient.getListOfEntriesOfLedgerCompletionTimeoutOpLogger
(package private) final OpStatsLogger	RequestStats.getListOfEntriesOfLedgerRequestStats
(package private) final OpStatsLogger	RequestStats.getListOfEntriesOfLedgerStats
(package private) final OpStatsLogger	RequestStats.longPollPreWaitStats
(package private) final OpStatsLogger	RequestStats.longPollReadRequestStats
(package private) final OpStatsLogger	RequestStats.longPollReadStats
(package private) final OpStatsLogger	RequestStats.longPollWaitStats
protected OpStatsLogger	CompletionValue.opLogger
(package private) final OpStatsLogger	RequestStats.readEntryBlockedStats
protected final OpStatsLogger	PerChannelBookieClient.readEntryOpLogger
(package private) final OpStatsLogger	RequestStats.readEntrySchedulingDelayStats
(package private) final OpStatsLogger	RequestStats.readEntryStats
protected final OpStatsLogger	PerChannelBookieClient.readLacOpLogger
(package private) final OpStatsLogger	RequestStats.readLacRequestStats
(package private) final OpStatsLogger	RequestStats.readLacStats
protected final OpStatsLogger	PerChannelBookieClient.readLacTimeoutOpLogger
(package private) final OpStatsLogger	RequestStats.readRequestStats
protected final OpStatsLogger	ReadEntryProcessorV3.readStats
protected final OpStatsLogger	PerChannelBookieClient.readTimeoutOpLogger
protected final OpStatsLogger	ReadEntryProcessorV3.reqStats
protected final OpStatsLogger	PerChannelBookieClient.startTLSOpLogger
protected final OpStatsLogger	PerChannelBookieClient.startTLSTimeoutOpLogger
(package private) final OpStatsLogger	BookkeeperInternalCallbacks.TimedGenericCallback.statsLogger
protected OpStatsLogger	CompletionValue.timeoutOpLogger
protected final OpStatsLogger	PerChannelBookieClient.writeLacOpLogger
(package private) final OpStatsLogger	RequestStats.writeLacRequestStats
(package private) final OpStatsLogger	RequestStats.writeLacStats
protected final OpStatsLogger	PerChannelBookieClient.writeLacTimeoutOpLogger

Methods in org.apache.bookkeeper.proto that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	RequestStats.getAddEntryBlockedStats()
OpStatsLogger	RequestStats.getAddEntryStats()
OpStatsLogger	RequestStats.getAddRequestStats()
OpStatsLogger	RequestStats.getChannelWriteStats()
OpStatsLogger	RequestStats.getFenceReadEntryStats()
OpStatsLogger	RequestStats.getFenceReadRequestStats()
OpStatsLogger	RequestStats.getFenceReadWaitStats()
OpStatsLogger	RequestStats.getForceLedgerRequestStats()
OpStatsLogger	RequestStats.getForceLedgerStats()
OpStatsLogger	RequestStats.getGetBookieInfoRequestStats()
OpStatsLogger	RequestStats.getGetBookieInfoStats()
OpStatsLogger	RequestStats.getGetListOfEntriesOfLedgerRequestStats()
OpStatsLogger	RequestStats.getGetListOfEntriesOfLedgerStats()
OpStatsLogger	RequestStats.getLongPollPreWaitStats()
OpStatsLogger	RequestStats.getLongPollReadRequestStats()
OpStatsLogger	RequestStats.getLongPollReadStats()
OpStatsLogger	RequestStats.getLongPollWaitStats()
OpStatsLogger	RequestStats.getReadEntryBlockedStats()
OpStatsLogger	RequestStats.getReadEntrySchedulingDelayStats()
OpStatsLogger	RequestStats.getReadEntryStats()
OpStatsLogger	RequestStats.getReadLacRequestStats()
OpStatsLogger	RequestStats.getReadLacStats()
OpStatsLogger	RequestStats.getReadRequestStats()
OpStatsLogger	RequestStats.getWriteLacRequestStats()
OpStatsLogger	RequestStats.getWriteLacStats()
OpStatsLogger	RequestStats.getWriteThreadQueuedLatency()

Methods in org.apache.bookkeeper.proto with parameters of type OpStatsLogger

Modifier and Type	Method	Description
protected void	ReadEntryProcessorV3.registerEvent(boolean failed, OpStatsLogger statsLogger, com.google.common.base.Stopwatch startTime)
protected void	ReadEntryProcessorV3.registerFailedEvent(OpStatsLogger statsLogger, com.google.common.base.Stopwatch startTime)
protected void	ReadEntryProcessorV3.registerSuccessfulEvent(OpStatsLogger statsLogger, com.google.common.base.Stopwatch startTime)
protected void	PacketProcessorBase.sendReadReqResponse(int rc, Object response, OpStatsLogger statsLogger, boolean throttle)
protected void	PacketProcessorBase.sendResponse(int rc, Object response, OpStatsLogger statsLogger)
protected void	PacketProcessorBaseV3.sendResponse(BookkeeperProtocol.StatusCode code, Object response, OpStatsLogger statsLogger)
protected void	WriteEntryProcessorV3.sendResponse(BookkeeperProtocol.StatusCode code, Object response, OpStatsLogger statsLogger)
protected void	PacketProcessorBase.sendResponseAndWait(int rc, Object response, OpStatsLogger statsLogger)	Write on the channel and wait until the write is completed.
protected void	PacketProcessorBase.sendWriteReqResponse(int rc, Object response, OpStatsLogger statsLogger)

Constructors in org.apache.bookkeeper.proto with parameters of type OpStatsLogger

Modifier	Constructor	Description
	TimedGenericCallback(BookkeeperInternalCallbacks.GenericCallback<T> cb, int successRc, OpStatsLogger statsLogger)

Uses of OpStatsLogger in org.apache.bookkeeper.replication

Methods in org.apache.bookkeeper.replication that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	AuditorStats.getAuditBookiesTime()
OpStatsLogger	AuditorStats.getBookieToLedgersMapCreationTime()
OpStatsLogger	AuditorStats.getCheckAllLedgersTime()
OpStatsLogger	AuditorStats.getNumBookiesPerLedger()
OpStatsLogger	AuditorStats.getNumFragmentsPerLedger()
OpStatsLogger	AuditorStats.getNumUnderReplicatedLedger()
OpStatsLogger	AuditorStats.getPlacementPolicyCheckTime()
OpStatsLogger	AuditorStats.getReplicasCheckTime()
OpStatsLogger	AuditorStats.getUnderReplicatedLedgerTotalSize()
OpStatsLogger	AuditorStats.getURLPublishTimeForLostBookies()

Uses of OpStatsLogger in org.apache.bookkeeper.stats

Classes in org.apache.bookkeeper.stats that implement OpStatsLogger

Modifier and Type	Class	Description
(package private) static class	NullStatsLogger.NullOpStatsLogger	A no-op OpStatsLogger.

Fields in org.apache.bookkeeper.stats with type parameters of type OpStatsLogger

Modifier and Type	Field	Description
protected final ConcurrentMap<String,OpStatsLogger>	CachingStatsLogger.opStatsLoggers

Methods in org.apache.bookkeeper.stats that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	CachingStatsLogger.getOpStatsLogger(String name)
OpStatsLogger	NullStatsLogger.getOpStatsLogger(String name)
OpStatsLogger	StatsLogger.getOpStatsLogger(String name)
OpStatsLogger	CachingStatsLogger.getThreadScopedOpStatsLogger(String name)	Thread-scoped stats not currently supported.
OpStatsLogger	NullStatsLogger.getThreadScopedOpStatsLogger(String name)
OpStatsLogger	StatsLogger.getThreadScopedOpStatsLogger(String name)

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

Classes in org.apache.bookkeeper.stats.codahale that implement OpStatsLogger

Modifier and Type	Class	Description
(package private) class	CodahaleOpStatsLogger

Methods in org.apache.bookkeeper.stats.codahale that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	CodahaleStatsLogger.getOpStatsLogger(String statName)
OpStatsLogger	FastCodahaleStatsLogger.getOpStatsLogger(String statName)
OpStatsLogger	CodahaleStatsLogger.getThreadScopedOpStatsLogger(String name)	Thread-scoped stats not currently supported.

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

Classes in org.apache.bookkeeper.stats.otel that implement OpStatsLogger

Modifier and Type	Class	Description
(package private) class	OtelOpStatsLogger

Methods in org.apache.bookkeeper.stats.otel that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	OtelStatsLogger.getOpStatsLogger(String name)
OpStatsLogger	OtelStatsLogger.getThreadScopedOpStatsLogger(String name)

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

Classes in org.apache.bookkeeper.stats.prometheus that implement OpStatsLogger

Modifier and Type	Class	Description
class	DataSketchesOpStatsLogger	OpStatsLogger implementation that uses DataSketches library to calculate the approximated latency quantiles.
class	ThreadScopedDataSketchesStatsLogger	OpStatsLogger implementation that lazily registers OpStatsLoggers per thread with added labels for the threadpool/thresd name and thread no.

Methods in org.apache.bookkeeper.stats.prometheus that return OpStatsLogger

Modifier and Type	Method	Description
OpStatsLogger	PrometheusStatsLogger.getOpStatsLogger(String name)
OpStatsLogger	PrometheusStatsLogger.getThreadScopedOpStatsLogger(String name)

Uses of OpStatsLogger in org.apache.bookkeeper.zookeeper

Fields in org.apache.bookkeeper.zookeeper declared as OpStatsLogger

Modifier and Type	Field	Description
(package private) final OpStatsLogger	ZooWorker.statsLogger

Methods in org.apache.bookkeeper.zookeeper with parameters of type OpStatsLogger

Modifier and Type	Method	Description
static <T> T	ZooWorker.syncCallWithRetries(ZooKeeperClient client, ZooWorker.ZooCallable<T> proc, RetryPolicy retryPolicy, com.google.common.util.concurrent.RateLimiter rateLimiter, OpStatsLogger statsLogger)	Execute a sync zookeeper operation with a given retry policy.

Constructors in org.apache.bookkeeper.zookeeper with parameters of type OpStatsLogger

Modifier	Constructor	Description
(package private)	ZkRetryRunnable(RetryPolicy retryPolicy, com.google.common.util.concurrent.RateLimiter rateLimiter, OpStatsLogger statsLogger)
(package private)	ZooWorker(RetryPolicy retryPolicy, OpStatsLogger statsLogger)