Uses of Interface
org.apache.bookkeeper.stats.StatsLogger
-
Packages that use StatsLogger Package Description org.apache.bookkeeper.bookie Provides a Bookie server that stores entries for clients.org.apache.bookkeeper.bookie.datainteg Package of the classes for defining bookie stats.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.api BookKeeper Client Public API.org.apache.bookkeeper.client.impl BookKeeper Client implementation package.org.apache.bookkeeper.common.component Component and lifecycle management.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.meta Classes for interacting with bookkeeper ledgers and ledger metadata.org.apache.bookkeeper.meta.zk ZooKeeper based metadata implementation.org.apache.bookkeeper.proto Classes related to the Bookkeeper protocol.org.apache.bookkeeper.replication Classes for replicating Bookkeeper data.org.apache.bookkeeper.server.component The lifecycle components that run on a bookie server.org.apache.bookkeeper.server.service Services running in a storage server (bookie).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 StatsLogger in org.apache.bookkeeper.bookie
Fields in org.apache.bookkeeper.bookie declared as StatsLogger Modifier and Type Field Description (package private) StatsLogger
BookieImpl. statsLogger
Methods in org.apache.bookkeeper.bookie with parameters of type StatsLogger Modifier and Type Method Description static LedgerDirsManager
BookieResources. createIndexDirsManager(ServerConfiguration conf, DiskChecker diskChecker, StatsLogger statsLogger, LedgerDirsManager fallback)
static LedgerDirsManager
BookieResources. createLedgerDirsManager(ServerConfiguration conf, DiskChecker diskChecker, StatsLogger statsLogger)
static LedgerStorage
BookieResources. createLedgerStorage(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
static MetadataBookieDriver
BookieResources. createMetadataDriver(ServerConfiguration conf, StatsLogger statsLogger)
Instantiate the metadata driver for the Bookie.void
InterleavedLedgerStorage. initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
void
LedgerStorage. initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
Initialize the LedgerStorage implementation.EnsemblePlacementPolicy
LocalBookieEnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer hashedWheelTimer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
void
SortedLedgerStorage. initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
void
InterleavedLedgerStorage. initializeWithEntryLogger(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, EntryLogger entryLogger, StatsLogger statsLogger)
(package private) void
InterleavedLedgerStorage. initializeWithEntryLogListener(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, DefaultEntryLogger.EntryLogListener entryLogListener, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
static BookieImpl
BookieImpl. newBookieImpl(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, java.util.function.Supplier<BookieServiceInfo> bookieServiceInfoProvider)
(package private) static Journal
Journal. newJournal(int journalIndex, java.io.File journalDirectory, ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, JournalAliveListener journalAliveListener)
Constructors in org.apache.bookkeeper.bookie with parameters of type StatsLogger Constructor Description BookieImpl(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, java.util.function.Supplier<BookieServiceInfo> bookieServiceInfoProvider)
BookieStateManager(ServerConfiguration conf, StatsLogger statsLogger, RegistrationManager rm, java.util.List<java.io.File> statusDirs, java.util.function.Supplier<BookieId> bookieIdSupplier, java.util.function.Supplier<BookieServiceInfo> bookieServiceInfoProvider)
BookieStateManager(ServerConfiguration conf, StatsLogger statsLogger, RegistrationManager rm, LedgerDirsManager ledgerDirsManager, java.util.function.Supplier<BookieServiceInfo> bookieServiceInfoProvider)
DefaultEntryLogger(ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, DefaultEntryLogger.EntryLogListener listener, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
EntryLogManagerForEntryLogPerLedger(ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, EntryLoggerAllocator entryLoggerAllocator, java.util.List<DefaultEntryLogger.EntryLogListener> listeners, DefaultEntryLogger.RecentEntryLogsStatus recentlyCreatedEntryLogsStatus, StatsLogger statsLogger)
EntryLogsPerLedgerCounter(StatsLogger statsLogger)
EntryMemTable(ServerConfiguration conf, CheckpointSource source, StatsLogger statsLogger)
Constructor.EntryMemTableWithParallelFlusher(ServerConfiguration conf, CheckpointSource source, StatsLogger statsLogger)
GarbageCollectorThread(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, CompactableLedgerStorage ledgerStorage, EntryLogger entryLogger, StatsLogger statsLogger)
Create a garbage collector thread.GarbageCollectorThread(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, CompactableLedgerStorage ledgerStorage, EntryLogger entryLogger, StatsLogger statsLogger, java.util.concurrent.ScheduledExecutorService gcExecutor)
Create a garbage collector thread.IndexInMemPageMgr(int pageSize, int entriesPerPage, ServerConfiguration conf, IndexPersistenceMgr indexPersistenceManager, StatsLogger statsLogger)
IndexPersistenceMgr(int pageSize, int entriesPerPage, ServerConfiguration conf, SnapshotMap<java.lang.Long,java.lang.Boolean> activeLedgers, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger)
Journal(int journalIndex, java.io.File journalDirectory, ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
Journal(int journalIndex, java.io.File journalDirectory, ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, JournalAliveListener journalAliveListener)
LedgerCacheImpl(ServerConfiguration conf, SnapshotMap<java.lang.Long,java.lang.Boolean> activeLedgers, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger)
LedgerDirsManager(ServerConfiguration conf, java.io.File[] dirs, DiskChecker diskChecker, StatsLogger statsLogger)
ReadOnlyBookie(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, java.util.function.Supplier<BookieServiceInfo> bookieServiceInfoProvider)
ScanAndCompareGarbageCollector(LedgerManager ledgerManager, CompactableLedgerStorage ledgerStorage, ServerConfiguration conf, StatsLogger statsLogger)
SyncThread(ServerConfiguration conf, LedgerDirsManager.LedgerDirsListener dirsListener, LedgerStorage ledgerStorage, CheckpointSource checkpointSource, StatsLogger statsLogger)
-
Uses of StatsLogger in org.apache.bookkeeper.bookie.datainteg
Constructors in org.apache.bookkeeper.bookie.datainteg with parameters of type StatsLogger Constructor Description DataIntegrityService(BookieConfiguration conf, StatsLogger statsLogger, DataIntegrityCheck check)
-
Uses of StatsLogger in org.apache.bookkeeper.bookie.stats
Fields in org.apache.bookkeeper.bookie.stats declared as StatsLogger Modifier and Type Field Description (package private) StatsLogger
BookieStats. statsLogger
(package private) StatsLogger
GarbageCollectorStats. statsLogger
Methods in org.apache.bookkeeper.bookie.stats that return StatsLogger Modifier and Type Method Description StatsLogger
BookieStats. getStatsLogger()
StatsLogger
GarbageCollectorStats. getStatsLogger()
Constructors in org.apache.bookkeeper.bookie.stats with parameters of type StatsLogger Constructor Description BookieStats(StatsLogger statsLogger, int numJournalDirs, int maxJournalQueueSize)
EntryMemTableStats(StatsLogger statsLogger)
GarbageCollectorStats(StatsLogger statsLogger, java.util.function.Supplier<java.lang.Integer> activeEntryLogCountSupplier, java.util.function.Supplier<java.lang.Long> activeEntryLogSpaceBytesSupplier, java.util.function.Supplier<java.lang.Integer> activeLedgerCountSupplier, java.util.function.Supplier<java.lang.Double> entryLogCompactRatioSupplier, java.util.function.Supplier<int[]> usageBuckets)
IndexInMemPageMgrStats(StatsLogger statsLogger)
IndexPersistenceMgrStats(StatsLogger statsLogger, java.util.function.Supplier<java.lang.Number> writeFileInfoCacheSizeSupplier, java.util.function.Supplier<java.lang.Number> readFileInfoCacheSizeSupplier)
JournalStats(StatsLogger statsLogger, long maxJournalMemoryBytes, java.util.function.Supplier<java.lang.Long> currentJournalMemoryBytes)
-
Uses of StatsLogger in org.apache.bookkeeper.bookie.storage.directentrylogger
Constructors in org.apache.bookkeeper.bookie.storage.directentrylogger with parameters of type StatsLogger Constructor Description DirectEntryLogger(java.io.File ledgerDir, EntryLogIds ids, NativeIO nativeIO, io.netty.buffer.ByteBufAllocator allocator, java.util.concurrent.ExecutorService writeExecutor, java.util.concurrent.ExecutorService flushExecutor, long maxFileSize, int maxSaneEntrySize, long totalWriteBufferSize, long totalReadBufferSize, int readBufferSize, int numReadThreads, int maxFdCacheTimeSeconds, Slogger slogParent, StatsLogger stats)
DirectEntryLoggerStats(StatsLogger stats)
-
Uses of StatsLogger in org.apache.bookkeeper.bookie.storage.ldb
Methods in org.apache.bookkeeper.bookie.storage.ldb with parameters of type StatsLogger Modifier and Type Method Description void
DbLedgerStorage. initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
void
SingleDirectoryDbLedgerStorage. initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
protected SingleDirectoryDbLedgerStorage
DbLedgerStorage. newSingleDirectoryDbLedgerStorage(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, EntryLogger entryLogger, StatsLogger statsLogger, long writeCacheSize, long readCacheSize, int readAheadCacheBatchSize, long readAheadCacheBatchBytesSize)
Constructors in org.apache.bookkeeper.bookie.storage.ldb with parameters of type StatsLogger Constructor Description DbLedgerStorageStats(StatsLogger stats, java.util.function.Supplier<java.lang.Long> writeCacheSizeSupplier, java.util.function.Supplier<java.lang.Long> writeCacheCountSupplier, java.util.function.Supplier<java.lang.Long> readCacheSizeSupplier, java.util.function.Supplier<java.lang.Long> readCacheCountSupplier)
EntryLocationIndex(ServerConfiguration conf, KeyValueStorageFactory storageFactory, java.lang.String basePath, StatsLogger stats)
EntryLocationIndexStats(StatsLogger statsLogger, java.util.function.Supplier<java.lang.Long> entriesCountSupplier)
LedgerMetadataIndex(ServerConfiguration conf, KeyValueStorageFactory storageFactory, java.lang.String basePath, StatsLogger stats)
LedgerMetadataIndexStats(StatsLogger statsLogger, java.util.function.Supplier<java.lang.Long> ledgersCountSupplier)
SingleDirectoryDbLedgerStorage(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, EntryLogger entryLogger, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, long writeCacheSize, long readCacheSize, int readAheadCacheBatchSize, long readAheadCacheBatchBytesSize)
-
Uses of StatsLogger in org.apache.bookkeeper.client
Fields in org.apache.bookkeeper.client declared as StatsLogger Modifier and Type Field Description (package private) StatsLogger
BookKeeper.Builder. statsLogger
protected StatsLogger
RackawareEnsemblePlacementPolicyImpl. statsLogger
protected StatsLogger
ZoneawareEnsemblePlacementPolicyImpl. statsLogger
Methods in org.apache.bookkeeper.client that return StatsLogger Modifier and Type Method Description (package private) StatsLogger
BookKeeper. getStatsLogger()
Methods in org.apache.bookkeeper.client with parameters of type StatsLogger Modifier and Type Method Description EnsemblePlacementPolicy
DefaultEnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer hashedWheelTimer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
EnsemblePlacementPolicy
EnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer hashedWheelTimer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
Initialize the policy.protected RackawareEnsemblePlacementPolicy
RackawareEnsemblePlacementPolicy. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, boolean useHostnameResolveLocalNodePlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
protected RackawareEnsemblePlacementPolicy
RackawareEnsemblePlacementPolicy. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
protected RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, boolean useHostnameResolveLocalNodePlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
Initialize the policy.protected RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
Initialize the policy.RegionAwareEnsemblePlacementPolicy
RegionAwareEnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
EnsemblePlacementPolicy
ZoneawareEnsemblePlacementPolicy. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
EnsemblePlacementPolicy
ZoneawareEnsemblePlacementPolicyImpl. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
protected EnsemblePlacementPolicy
BookKeeper. initializeEnsemblePlacementPolicy(ClientConfiguration conf, DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
static BookKeeperClientStats
BookKeeperClientStats. newInstance(StatsLogger stats)
BookKeeper.Builder
BookKeeper.Builder. setStatsLogger(StatsLogger statsLogger)
Deprecated.since 4.5, useBookKeeper.Builder.statsLogger(StatsLogger)
BookKeeper.Builder
BookKeeper.Builder. statsLogger(StatsLogger statsLogger)
Configure the bookkeeper client with a providedStatsLogger
.Constructors in org.apache.bookkeeper.client with parameters of type StatsLogger Constructor Description BookieWatcherImpl(ClientConfiguration conf, EnsemblePlacementPolicy placementPolicy, RegistrationClient registrationClient, BookieAddressResolver bookieAddressResolver, StatsLogger statsLogger)
BookKeeper(ClientConfiguration conf, org.apache.zookeeper.ZooKeeper zkc, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.buffer.ByteBufAllocator byteBufAllocator, StatsLogger rootStatsLogger, DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer requestTimer, FeatureProvider featureProvider)
Constructor for use with the builder.BookKeeperAdmin(BookKeeper bkc, StatsLogger statsLogger, ClientConfiguration conf)
Constructor that takes in a BookKeeper instance .LedgerFragmentReplicator(BookKeeper bkc, StatsLogger statsLogger, ClientConfiguration conf)
-
Uses of StatsLogger in org.apache.bookkeeper.client.api
Methods in org.apache.bookkeeper.client.api with parameters of type StatsLogger Modifier and Type Method Description BookKeeperBuilder
BookKeeperBuilder. statsLogger(StatsLogger statsLogger)
Configure the bookkeeper client with a providedStatsLogger
. -
Uses of StatsLogger in org.apache.bookkeeper.client.impl
Methods in org.apache.bookkeeper.client.impl with parameters of type StatsLogger Modifier and Type Method Description BookKeeperBuilder
BookKeeperBuilderImpl. statsLogger(StatsLogger statsLogger)
Constructors in org.apache.bookkeeper.client.impl with parameters of type StatsLogger Constructor Description BookKeeperClientStatsImpl(StatsLogger stats)
-
Uses of StatsLogger in org.apache.bookkeeper.common.component
Fields in org.apache.bookkeeper.common.component declared as StatsLogger Modifier and Type Field Description protected StatsLogger
AbstractLifecycleComponent. statsLogger
Methods in org.apache.bookkeeper.common.component that return StatsLogger Modifier and Type Method Description protected StatsLogger
AbstractLifecycleComponent. getStatsLogger()
Constructors in org.apache.bookkeeper.common.component with parameters of type StatsLogger Constructor Description AbstractLifecycleComponent(java.lang.String componentName, ConfT conf, StatsLogger statsLogger)
RxSchedulerLifecycleComponent(java.lang.String componentName, ComponentConfiguration conf, StatsLogger stats, io.reactivex.rxjava3.core.Scheduler scheduler, java.util.concurrent.ExecutorService rxExecutor)
-
Uses of StatsLogger in org.apache.bookkeeper.common.stats
Classes in org.apache.bookkeeper.common.stats that implement StatsLogger Modifier and Type Class Description (package private) static class
BroadCastStatsLogger.MasterSlave
(package private) static class
BroadCastStatsLogger.Two
Fields in org.apache.bookkeeper.common.stats declared as StatsLogger Modifier and Type Field Description protected StatsLogger
BroadCastStatsLogger.Two. first
protected StatsLogger
BroadCastStatsLogger.Two. second
Methods in org.apache.bookkeeper.common.stats that return StatsLogger Modifier and Type Method Description static StatsLogger
BroadCastStatsLogger. masterslave(StatsLogger master, StatsLogger slave)
Create a broadcast stats logger of two stats loggersmaster
andslave
.StatsLogger
BroadCastStatsLogger.MasterSlave. scope(java.lang.String scope)
StatsLogger
BroadCastStatsLogger.Two. scope(java.lang.String scope)
static StatsLogger
BroadCastStatsLogger. two(StatsLogger first, StatsLogger second)
Create a broadcast stats logger of two stats loggers `first
` and `second
`.Methods in org.apache.bookkeeper.common.stats with parameters of type StatsLogger Modifier and Type Method Description static StatsLogger
BroadCastStatsLogger. masterslave(StatsLogger master, StatsLogger slave)
Create a broadcast stats logger of two stats loggersmaster
andslave
.void
BroadCastStatsLogger.Two. removeScope(java.lang.String scope, StatsLogger statsLogger)
static StatsLogger
BroadCastStatsLogger. two(StatsLogger first, StatsLogger second)
Create a broadcast stats logger of two stats loggers `first
` and `second
`. -
Uses of StatsLogger in org.apache.bookkeeper.common.util
Fields in org.apache.bookkeeper.common.util declared as StatsLogger Modifier and Type Field Description protected StatsLogger
OrderedExecutor.AbstractBuilder. statsLogger
Methods in org.apache.bookkeeper.common.util with parameters of type StatsLogger Modifier and Type Method Description void
SingleThreadExecutor. registerMetrics(StatsLogger statsLogger)
OrderedExecutor.AbstractBuilder<T>
OrderedExecutor.AbstractBuilder. statsLogger(StatsLogger statsLogger)
Constructors in org.apache.bookkeeper.common.util with parameters of type StatsLogger Constructor Description OrderedExecutor(java.lang.String baseName, int numThreads, java.util.concurrent.ThreadFactory threadFactory, StatsLogger statsLogger, boolean traceTaskExecution, boolean preserveMdcForTaskExecution, long warnTimeMicroSec, int maxTasksInQueue, boolean enableBusyWait, boolean enableThreadScopedMetrics)
Constructs Safe executor. -
Uses of StatsLogger in org.apache.bookkeeper.meta
Methods in org.apache.bookkeeper.meta with parameters of type StatsLogger Modifier and Type Method Description MetadataBookieDriver
MetadataBookieDriver. initialize(ServerConfiguration conf, StatsLogger statsLogger)
Initialize the metadata driver.MetadataClientDriver
MetadataClientDriver. initialize(ClientConfiguration conf, java.util.concurrent.ScheduledExecutorService scheduler, StatsLogger statsLogger, java.util.Optional<java.lang.Object> ctx)
Initialize the metadata driver.MetadataBookieDriver
NullMetadataBookieDriver. initialize(ServerConfiguration conf, StatsLogger statsLogger)
Constructors in org.apache.bookkeeper.meta with parameters of type StatsLogger Constructor Description ZkLedgerAuditorManager(org.apache.zookeeper.ZooKeeper zkc, ServerConfiguration conf, StatsLogger statsLogger)
-
Uses of StatsLogger in org.apache.bookkeeper.meta.zk
Fields in org.apache.bookkeeper.meta.zk declared as StatsLogger Modifier and Type Field Description protected StatsLogger
ZKMetadataDriverBase. statsLogger
Methods in org.apache.bookkeeper.meta.zk with parameters of type StatsLogger Modifier and Type Method Description MetadataBookieDriver
ZKMetadataBookieDriver. initialize(ServerConfiguration conf, StatsLogger statsLogger)
MetadataClientDriver
ZKMetadataClientDriver. initialize(ClientConfiguration conf, java.util.concurrent.ScheduledExecutorService scheduler, StatsLogger statsLogger, java.util.Optional<java.lang.Object> optionalCtx)
protected void
ZKMetadataDriverBase. initialize(AbstractConfiguration<?> conf, StatsLogger statsLogger, RetryPolicy zkRetryPolicy, java.util.Optional<java.lang.Object> optionalCtx)
-
Uses of StatsLogger in org.apache.bookkeeper.proto
Methods in org.apache.bookkeeper.proto with parameters of type StatsLogger Modifier and Type Method Description static BookieServer
BookieServer. newBookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection)
Constructors in org.apache.bookkeeper.proto with parameters of type StatsLogger Constructor Description BookieClientImpl(ClientConfiguration conf, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.buffer.ByteBufAllocator allocator, OrderedExecutor executor, java.util.concurrent.ScheduledExecutorService scheduler, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
BookieRequestProcessor(ServerConfiguration serverCfg, Bookie bookie, StatsLogger statsLogger, SecurityHandlerFactory shFactory, io.netty.buffer.ByteBufAllocator allocator, io.netty.channel.group.ChannelGroup allChannels)
BookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection)
PerChannelBookieClient(ClientConfiguration conf, OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.buffer.ByteBufAllocator allocator, BookieId bookieId, StatsLogger parentStatsLogger, ClientAuthProvider.Factory authProviderFactory, com.google.protobuf.ExtensionRegistry extRegistry, PerChannelBookieClientPool pcbcPool, SecurityHandlerFactory shFactory, BookieAddressResolver bookieAddressResolver)
PerChannelBookieClient(ClientConfiguration conf, OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, BookieId bookieId, StatsLogger parentStatsLogger, ClientAuthProvider.Factory authProviderFactory, com.google.protobuf.ExtensionRegistry extRegistry, PerChannelBookieClientPool pcbcPool, BookieAddressResolver bookieAddressResolver)
RequestStats(StatsLogger statsLogger)
-
Uses of StatsLogger in org.apache.bookkeeper.replication
Methods in org.apache.bookkeeper.replication that return StatsLogger Modifier and Type Method Description StatsLogger
AuditorStats. getStatsLogger()
Methods in org.apache.bookkeeper.replication with parameters of type StatsLogger Modifier and Type Method Description (package private) static BookKeeper
Auditor. createBookKeeperClient(ServerConfiguration conf, StatsLogger statsLogger)
Constructors in org.apache.bookkeeper.replication with parameters of type StatsLogger Constructor Description Auditor(java.lang.String bookieIdentifier, ServerConfiguration conf, BookKeeper bkc, boolean ownBkc, BookKeeperAdmin admin, boolean ownAdmin, StatsLogger statsLogger)
Auditor(java.lang.String bookieIdentifier, ServerConfiguration conf, BookKeeper bkc, boolean ownBkc, StatsLogger statsLogger)
Auditor(java.lang.String bookieIdentifier, ServerConfiguration conf, StatsLogger statsLogger)
AuditorElector(java.lang.String bookieId, ServerConfiguration conf, BookKeeper bkc, StatsLogger statsLogger, boolean ownBkc)
AuditorElector for performing the auditor election.AuditorStats(StatsLogger statsLogger)
AutoRecoveryMain(ServerConfiguration conf, StatsLogger statsLogger)
ReplicationWorker(ServerConfiguration conf, BookKeeper bkc, boolean ownBkc, StatsLogger statsLogger)
ReplicationWorker(ServerConfiguration conf, StatsLogger statsLogger)
Replication worker for replicating the ledger fragments from UnderReplicationManager to the targetBookie. -
Uses of StatsLogger in org.apache.bookkeeper.server.component
Methods in org.apache.bookkeeper.server.component with parameters of type StatsLogger Modifier and Type Method Description static java.util.List<ServerLifecycleComponent>
ServerLifecycleComponent. loadServerComponents(java.lang.String[] componentClassNames, BookieConfiguration conf, StatsLogger statsLogger)
(package private) static ServerLifecycleComponent
ServerLifecycleComponent. newComponent(java.lang.Class<? extends ServerLifecycleComponent> theCls, BookieConfiguration conf, StatsLogger statsLogger)
Constructors in org.apache.bookkeeper.server.component with parameters of type StatsLogger Constructor Description ServerLifecycleComponent(java.lang.String componentName, BookieConfiguration conf, StatsLogger statsLogger)
-
Uses of StatsLogger in org.apache.bookkeeper.server.service
Constructors in org.apache.bookkeeper.server.service with parameters of type StatsLogger Constructor Description AutoRecoveryService(BookieConfiguration conf, StatsLogger statsLogger)
BookieService(BookieConfiguration conf, Bookie bookie, StatsLogger statsLogger, ByteBufAllocatorWithOomHandler allocator, UncleanShutdownDetection uncleanShutdownDetection)
HttpService(BKHttpServiceProvider provider, BookieConfiguration conf, StatsLogger statsLogger)
ScrubberService(StatsLogger logger, BookieConfiguration conf, LedgerStorage ledgerStorage)
-
Uses of StatsLogger in org.apache.bookkeeper.stats
Classes in org.apache.bookkeeper.stats that implement StatsLogger Modifier and Type Class Description class
CachingStatsLogger
AStatsLogger
that caches the stats objects created by otherStatsLogger
.class
NullStatsLogger
A no-opStatsLogger
.Fields in org.apache.bookkeeper.stats declared as StatsLogger Modifier and Type Field Description (package private) StatsLogger
NullStatsProvider. nullStatsLogger
protected StatsLogger
CachingStatsLogger. underlying
Fields in org.apache.bookkeeper.stats with type parameters of type StatsLogger Modifier and Type Field Description protected java.util.concurrent.ConcurrentMap<java.lang.String,StatsLogger>
CachingStatsLogger. scopeStatsLoggers
protected java.util.concurrent.ConcurrentMap<java.lang.String,StatsLogger>
CachingStatsProvider. statsLoggers
Methods in org.apache.bookkeeper.stats that return StatsLogger Modifier and Type Method Description StatsLogger
CachingStatsProvider. getStatsLogger(java.lang.String scope)
StatsLogger
NullStatsProvider. getStatsLogger(java.lang.String scope)
StatsLogger
StatsProvider. getStatsLogger(java.lang.String scope)
Return the stats logger to a given scope.StatsLogger
CachingStatsLogger. scope(java.lang.String name)
StatsLogger
NullStatsLogger. scope(java.lang.String name)
StatsLogger
StatsLogger. scope(java.lang.String name)
Provide the stats logger under scope name.default StatsLogger
StatsLogger. scopeLabel(java.lang.String labelName, java.lang.String labelValue)
Provide the stats logger with an attached label.Methods in org.apache.bookkeeper.stats with parameters of type StatsLogger Modifier and Type Method Description void
CachingStatsLogger. removeScope(java.lang.String name, StatsLogger statsLogger)
void
NullStatsLogger. removeScope(java.lang.String name, StatsLogger statsLogger)
void
StatsLogger. removeScope(java.lang.String name, StatsLogger statsLogger)
Remove the given statsLogger for scope name.Constructors in org.apache.bookkeeper.stats with parameters of type StatsLogger Constructor Description AlertStatsLogger(StatsLogger globalStatsLogger, java.lang.String alertStatName)
AlertStatsLogger(StatsLogger globalStatsLogger, java.lang.String scope, java.lang.String alertStatName)
CachingStatsLogger(StatsLogger statsLogger)
-
Uses of StatsLogger in org.apache.bookkeeper.stats.codahale
Classes in org.apache.bookkeeper.stats.codahale that implement StatsLogger Modifier and Type Class Description class
CodahaleStatsLogger
AStatsLogger
implemented based on Codahale metrics library.class
FastCodahaleStatsLogger
AStatsLogger
implemented based on Codahale metrics library.Methods in org.apache.bookkeeper.stats.codahale that return StatsLogger Modifier and Type Method Description StatsLogger
CodahaleMetricsProvider. getStatsLogger(java.lang.String name)
StatsLogger
FastCodahaleMetricsProvider. getStatsLogger(java.lang.String name)
StatsLogger
CodahaleStatsLogger. scope(java.lang.String scope)
StatsLogger
FastCodahaleStatsLogger. scope(java.lang.String scope)
Methods in org.apache.bookkeeper.stats.codahale with parameters of type StatsLogger Modifier and Type Method Description void
CodahaleStatsLogger. removeScope(java.lang.String name, StatsLogger statsLogger)
-
Uses of StatsLogger in org.apache.bookkeeper.stats.otel
Classes in org.apache.bookkeeper.stats.otel that implement StatsLogger Modifier and Type Class Description class
OtelStatsLogger
Methods in org.apache.bookkeeper.stats.otel that return StatsLogger Modifier and Type Method Description StatsLogger
OtelMetricsProvider. getStatsLogger(java.lang.String scope)
StatsLogger
OtelStatsLogger. scope(java.lang.String name)
StatsLogger
OtelStatsLogger. scopeLabel(java.lang.String labelName, java.lang.String labelValue)
Methods in org.apache.bookkeeper.stats.otel with parameters of type StatsLogger Modifier and Type Method Description void
OtelStatsLogger. removeScope(java.lang.String name, StatsLogger statsLogger)
-
Uses of StatsLogger in org.apache.bookkeeper.stats.prometheus
Classes in org.apache.bookkeeper.stats.prometheus that implement StatsLogger Modifier and Type Class Description class
PrometheusStatsLogger
APrometheus
basedStatsLogger
implementation.Methods in org.apache.bookkeeper.stats.prometheus that return StatsLogger Modifier and Type Method Description StatsLogger
PrometheusMetricsProvider. getStatsLogger(java.lang.String scope)
StatsLogger
PrometheusStatsLogger. scope(java.lang.String name)
StatsLogger
PrometheusStatsLogger. scopeLabel(java.lang.String labelName, java.lang.String labelValue)
Methods in org.apache.bookkeeper.stats.prometheus with parameters of type StatsLogger Modifier and Type Method Description void
PrometheusStatsLogger. removeScope(java.lang.String name, StatsLogger statsLogger)
-
Uses of StatsLogger in org.apache.bookkeeper.zookeeper
Fields in org.apache.bookkeeper.zookeeper declared as StatsLogger Modifier and Type Field Description (package private) StatsLogger
ZooKeeperClient.Builder. statsLogger
Methods in org.apache.bookkeeper.zookeeper with parameters of type StatsLogger Modifier and Type Method Description ZooKeeperClient.Builder
ZooKeeperClient.Builder. statsLogger(StatsLogger statsLogger)
Constructors in org.apache.bookkeeper.zookeeper with parameters of type StatsLogger Constructor Description ZooKeeperClient(java.lang.String connectString, int sessionTimeoutMs, ZooKeeperWatcherBase watcherManager, RetryPolicy connectRetryPolicy, RetryPolicy operationRetryPolicy, StatsLogger statsLogger, int retryExecThreadCount, double rate, boolean allowReadOnlyMode)
ZooKeeperWatcherBase(int zkSessionTimeOut, boolean allowReadOnlyMode, java.util.Set<org.apache.zookeeper.Watcher> childWatchers, StatsLogger statsLogger)
ZooKeeperWatcherBase(int zkSessionTimeOut, boolean allowReadOnlyMode, StatsLogger statsLogger)
-