Uses of Interface
org.apache.bookkeeper.stats.StatsLogger
Packages that use StatsLogger
Package
Description
Provides a Bookie server that stores entries for clients.
Package of the classes for defining bookie stats.
Package of the classes for defining bookie stats.
Support for bookie entry logs using Direct IO.
Classes related to DB based ledger storage.
BookKeeper Client.
BookKeeper Client Public API.
BookKeeper Client implementation package.
Component and lifecycle management.
Stats Related Utils.
defines the utilities for allocator used across the project.
Classes for interacting with bookkeeper ledgers and ledger metadata.
ZooKeeper based metadata implementation.
Classes related to the Bookkeeper protocol.
Classes for replicating Bookkeeper data.
The lifecycle components that run on a bookie server.
Services running in a storage server (bookie).
A lightweight stats library used for exporting bookkeeper stats.
A lightweight stats library implementation based on Codahale metrics library.
A stats provider implementation based on OpenTelemetry.
A stats provider implementation based on {@link https://prometheus.io/}.
A simple retryable zookeeper wrapper provided in bookkeeper.
-
Uses of StatsLogger in org.apache.bookkeeper.bookie
Fields in org.apache.bookkeeper.bookie declared as StatsLoggerMethods in org.apache.bookkeeper.bookie with parameters of type StatsLoggerModifier and TypeMethodDescriptionstatic LedgerDirsManagerBookieResources.createIndexDirsManager(ServerConfiguration conf, DiskChecker diskChecker, StatsLogger statsLogger, LedgerDirsManager fallback) static LedgerDirsManagerBookieResources.createLedgerDirsManager(ServerConfiguration conf, DiskChecker diskChecker, StatsLogger statsLogger) static LedgerStorageBookieResources.createLedgerStorage(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) static MetadataBookieDriverBookieResources.createMetadataDriver(ServerConfiguration conf, StatsLogger statsLogger) Instantiate the metadata driver for the Bookie.voidInterleavedLedgerStorage.initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) voidLedgerStorage.initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) Initialize the LedgerStorage implementation.LocalBookieEnsemblePlacementPolicy.initialize(ClientConfiguration conf, Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer hashedWheelTimer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver) voidSortedLedgerStorage.initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) voidInterleavedLedgerStorage.initializeWithEntryLogger(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, EntryLogger entryLogger, StatsLogger statsLogger) (package private) voidInterleavedLedgerStorage.initializeWithEntryLogListener(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, DefaultEntryLogger.EntryLogListener entryLogListener, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) static BookieImplBookieImpl.newBookieImpl(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, Supplier<BookieServiceInfo> bookieServiceInfoProvider) (package private) static JournalJournal.newJournal(int journalIndex, 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 StatsLoggerModifierConstructorDescriptionBookieImpl(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, Supplier<BookieServiceInfo> bookieServiceInfoProvider) BookieStateManager(ServerConfiguration conf, StatsLogger statsLogger, RegistrationManager rm, List<File> statusDirs, Supplier<BookieId> bookieIdSupplier, Supplier<BookieServiceInfo> bookieServiceInfoProvider) BookieStateManager(ServerConfiguration conf, StatsLogger statsLogger, RegistrationManager rm, LedgerDirsManager ledgerDirsManager, Supplier<BookieServiceInfo> bookieServiceInfoProvider) DefaultEntryLogger(ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, DefaultEntryLogger.EntryLogListener listener, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) (package private)EntryLogManagerForEntryLogPerLedger(ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, EntryLoggerAllocator entryLoggerAllocator, List<DefaultEntryLogger.EntryLogListener> listeners, DefaultEntryLogger.RecentEntryLogsStatus recentlyCreatedEntryLogsStatus, StatsLogger statsLogger) (package private)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, 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<Long, Boolean> activeLedgers, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger) Journal(int journalIndex, File journalDirectory, ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) Journal(int journalIndex, File journalDirectory, ServerConfiguration conf, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, JournalAliveListener journalAliveListener) LedgerCacheImpl(ServerConfiguration conf, SnapshotMap<Long, Boolean> activeLedgers, LedgerDirsManager ledgerDirsManager, StatsLogger statsLogger) LedgerDirsManager(ServerConfiguration conf, 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, 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 StatsLoggerModifierConstructorDescriptionDataIntegrityService(BookieConfiguration conf, StatsLogger statsLogger, DataIntegrityCheck check) -
Uses of StatsLogger in org.apache.bookkeeper.bookie.stats
Fields in org.apache.bookkeeper.bookie.stats declared as StatsLoggerModifier and TypeFieldDescription(package private) final StatsLoggerBookieStats.statsLogger(package private) final StatsLoggerGarbageCollectorStats.statsLoggerMethods in org.apache.bookkeeper.bookie.stats that return StatsLoggerModifier and TypeMethodDescriptionBookieStats.getStatsLogger()GarbageCollectorStats.getStatsLogger()Constructors in org.apache.bookkeeper.bookie.stats with parameters of type StatsLoggerModifierConstructorDescriptionBookieStats(StatsLogger statsLogger, int numJournalDirs, int maxJournalQueueSize) EntryMemTableStats(StatsLogger statsLogger) GarbageCollectorStats(StatsLogger statsLogger, Supplier<Integer> activeEntryLogCountSupplier, Supplier<Long> activeEntryLogSpaceBytesSupplier, Supplier<Long> entryLogSpaceBytesSupplier, Supplier<Integer> activeLedgerCountSupplier, Supplier<Double> entryLogCompactRatioSupplier, Supplier<int[]> usageBuckets) IndexInMemPageMgrStats(StatsLogger statsLogger) IndexPersistenceMgrStats(StatsLogger statsLogger, Supplier<Number> writeFileInfoCacheSizeSupplier, Supplier<Number> readFileInfoCacheSizeSupplier) JournalStats(StatsLogger statsLogger, long maxJournalMemoryBytes, Supplier<Long> currentJournalMemoryBytes) -
Uses of StatsLogger in org.apache.bookkeeper.bookie.storage.directentrylogger
Constructors in org.apache.bookkeeper.bookie.storage.directentrylogger with parameters of type StatsLoggerModifierConstructorDescriptionDirectEntryLogger(File ledgerDir, EntryLogIds ids, NativeIO nativeIO, io.netty.buffer.ByteBufAllocator allocator, ExecutorService writeExecutor, ExecutorService flushExecutor, long maxFileSize, int maxSaneEntrySize, long totalWriteBufferSize, long totalReadBufferSize, int readBufferSize, int numReadThreads, int maxFdCacheTimeSeconds, Slogger slogParent, StatsLogger stats) (package private) -
Uses of StatsLogger in org.apache.bookkeeper.bookie.storage.ldb
Methods in org.apache.bookkeeper.bookie.storage.ldb with parameters of type StatsLoggerModifier and TypeMethodDescriptionvoidDbLedgerStorage.initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) voidSingleDirectoryDbLedgerStorage.initialize(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) protected SingleDirectoryDbLedgerStorageDbLedgerStorage.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 StatsLoggerModifierConstructorDescription(package private)DbLedgerStorageStats(StatsLogger stats, Supplier<Long> writeCacheSizeSupplier, Supplier<Long> writeCacheCountSupplier, Supplier<Long> readCacheSizeSupplier, Supplier<Long> readCacheCountSupplier) EntryLocationIndex(ServerConfiguration conf, KeyValueStorageFactory storageFactory, String basePath, StatsLogger stats) (package private)EntryLocationIndexStats(StatsLogger statsLogger, Supplier<Long> entriesCountSupplier) LedgerMetadataIndex(ServerConfiguration conf, KeyValueStorageFactory storageFactory, String basePath, StatsLogger stats) (package private)LedgerMetadataIndexStats(StatsLogger statsLogger, Supplier<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 StatsLoggerModifier and TypeFieldDescription(package private) StatsLoggerBookKeeper.Builder.statsLoggerprotected StatsLoggerRackawareEnsemblePlacementPolicyImpl.statsLoggerprotected StatsLoggerZoneawareEnsemblePlacementPolicyImpl.statsLoggerMethods in org.apache.bookkeeper.client that return StatsLoggerMethods in org.apache.bookkeeper.client with parameters of type StatsLoggerModifier and TypeMethodDescriptionDefaultEnsemblePlacementPolicy.initialize(ClientConfiguration conf, Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer hashedWheelTimer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver) EnsemblePlacementPolicy.initialize(ClientConfiguration conf, Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer hashedWheelTimer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver) Initialize the policy.protected RackawareEnsemblePlacementPolicyRackawareEnsemblePlacementPolicy.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 RackawareEnsemblePlacementPolicyRackawareEnsemblePlacementPolicy.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.initialize(ClientConfiguration conf, Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver) protected RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.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 RackawareEnsemblePlacementPolicyImplRackawareEnsemblePlacementPolicyImpl.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.initialize(ClientConfiguration conf, Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver) ZoneawareEnsemblePlacementPolicy.initialize(ClientConfiguration conf, Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver) ZoneawareEnsemblePlacementPolicyImpl.initialize(ClientConfiguration conf, Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver) protected EnsemblePlacementPolicyBookKeeper.initializeEnsemblePlacementPolicy(ClientConfiguration conf, DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver) static BookKeeperClientStatsBookKeeperClientStats.newInstance(StatsLogger stats) BookKeeper.Builder.setStatsLogger(StatsLogger statsLogger) Deprecated.BookKeeper.Builder.statsLogger(StatsLogger statsLogger) Configure the bookkeeper client with a providedStatsLogger.Constructors in org.apache.bookkeeper.client with parameters of type StatsLoggerModifierConstructorDescriptionBookieWatcherImpl(ClientConfiguration conf, EnsemblePlacementPolicy placementPolicy, RegistrationClient registrationClient, BookieAddressResolver bookieAddressResolver, StatsLogger statsLogger) (package private)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 StatsLoggerModifier and TypeMethodDescriptionBookKeeperBuilder.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 StatsLoggerConstructors in org.apache.bookkeeper.client.impl with parameters of type StatsLogger -
Uses of StatsLogger in org.apache.bookkeeper.common.component
Fields in org.apache.bookkeeper.common.component declared as StatsLoggerModifier and TypeFieldDescriptionprotected final StatsLoggerAbstractLifecycleComponent.statsLoggerMethods in org.apache.bookkeeper.common.component that return StatsLoggerModifier and TypeMethodDescriptionprotected StatsLoggerAbstractLifecycleComponent.getStatsLogger()Constructors in org.apache.bookkeeper.common.component with parameters of type StatsLoggerModifierConstructorDescriptionprotectedAbstractLifecycleComponent(String componentName, ConfT conf, StatsLogger statsLogger) RxSchedulerLifecycleComponent(String componentName, ComponentConfiguration conf, StatsLogger stats, io.reactivex.rxjava3.core.Scheduler scheduler, ExecutorService rxExecutor) -
Uses of StatsLogger in org.apache.bookkeeper.common.stats
Classes in org.apache.bookkeeper.common.stats that implement StatsLoggerModifier and TypeClassDescription(package private) static class(package private) static classFields in org.apache.bookkeeper.common.stats declared as StatsLoggerModifier and TypeFieldDescriptionprotected final StatsLoggerBroadCastStatsLogger.Two.firstprotected final StatsLoggerBroadCastStatsLogger.Two.secondMethods in org.apache.bookkeeper.common.stats that return StatsLoggerModifier and TypeMethodDescriptionstatic StatsLoggerBroadCastStatsLogger.masterslave(StatsLogger master, StatsLogger slave) Create a broadcast stats logger of two stats loggersmasterandslave.static StatsLoggerBroadCastStatsLogger.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 StatsLoggerModifier and TypeMethodDescriptionstatic StatsLoggerBroadCastStatsLogger.masterslave(StatsLogger master, StatsLogger slave) Create a broadcast stats logger of two stats loggersmasterandslave.voidBroadCastStatsLogger.Two.removeScope(String scope, StatsLogger statsLogger) static StatsLoggerBroadCastStatsLogger.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 StatsLoggerModifier and TypeFieldDescriptionprotected StatsLoggerOrderedExecutor.AbstractBuilder.statsLoggerMethods in org.apache.bookkeeper.common.util with parameters of type StatsLoggerModifier and TypeMethodDescriptionvoidSingleThreadExecutor.registerMetrics(StatsLogger statsLogger) OrderedExecutor.AbstractBuilder.statsLogger(StatsLogger statsLogger) Constructors in org.apache.bookkeeper.common.util with parameters of type StatsLoggerModifierConstructorDescriptionprotectedOrderedExecutor(String baseName, int numThreads, 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 StatsLoggerModifier and TypeMethodDescriptionMetadataBookieDriver.initialize(ServerConfiguration conf, StatsLogger statsLogger) Initialize the metadata driver.MetadataClientDriver.initialize(ClientConfiguration conf, ScheduledExecutorService scheduler, StatsLogger statsLogger, Optional<Object> ctx) Initialize the metadata driver.NullMetadataBookieDriver.initialize(ServerConfiguration conf, StatsLogger statsLogger) Constructors in org.apache.bookkeeper.meta with parameters of type StatsLoggerModifierConstructorDescriptionZkLedgerAuditorManager(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 StatsLoggerMethods in org.apache.bookkeeper.meta.zk with parameters of type StatsLoggerModifier and TypeMethodDescriptionZKMetadataBookieDriver.initialize(ServerConfiguration conf, StatsLogger statsLogger) ZKMetadataClientDriver.initialize(ClientConfiguration conf, ScheduledExecutorService scheduler, StatsLogger statsLogger, Optional<Object> optionalCtx) protected voidZKMetadataDriverBase.initialize(AbstractConfiguration<?> conf, StatsLogger statsLogger, RetryPolicy zkRetryPolicy, Optional<Object> optionalCtx) -
Uses of StatsLogger in org.apache.bookkeeper.proto
Methods in org.apache.bookkeeper.proto with parameters of type StatsLoggerModifier and TypeMethodDescriptionstatic BookieServerBookieServer.newBookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection) Constructors in org.apache.bookkeeper.proto with parameters of type StatsLoggerModifierConstructorDescriptionBookieClientImpl(ClientConfiguration conf, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.buffer.ByteBufAllocator allocator, OrderedExecutor executor, 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 StatsLoggerMethods in org.apache.bookkeeper.replication with parameters of type StatsLoggerModifier and TypeMethodDescription(package private) static BookKeeperAuditor.createBookKeeperClient(ServerConfiguration conf, StatsLogger statsLogger) Constructors in org.apache.bookkeeper.replication with parameters of type StatsLoggerModifierConstructorDescriptionAuditor(String bookieIdentifier, ServerConfiguration conf, BookKeeper bkc, boolean ownBkc, BookKeeperAdmin admin, boolean ownAdmin, StatsLogger statsLogger) Auditor(String bookieIdentifier, ServerConfiguration conf, BookKeeper bkc, boolean ownBkc, StatsLogger statsLogger) Auditor(String bookieIdentifier, ServerConfiguration conf, StatsLogger statsLogger) AuditorElector(String bookieId, ServerConfiguration conf, BookKeeper bkc, StatsLogger statsLogger, boolean ownBkc) AuditorElector for performing the auditor election.AuditorStats(StatsLogger statsLogger) AutoRecoveryMain(ServerConfiguration conf, StatsLogger statsLogger) (package private)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 StatsLoggerModifier and TypeMethodDescriptionstatic List<ServerLifecycleComponent>ServerLifecycleComponent.loadServerComponents(String[] componentClassNames, BookieConfiguration conf, StatsLogger statsLogger) (package private) static ServerLifecycleComponentServerLifecycleComponent.newComponent(Class<? extends ServerLifecycleComponent> theCls, BookieConfiguration conf, StatsLogger statsLogger) Constructors in org.apache.bookkeeper.server.component with parameters of type StatsLoggerModifierConstructorDescriptionprotectedServerLifecycleComponent(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 StatsLoggerModifierConstructorDescriptionAutoRecoveryService(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 StatsLoggerModifier and TypeClassDescriptionclassAStatsLoggerthat caches the stats objects created by otherStatsLogger.classA no-opStatsLogger.Fields in org.apache.bookkeeper.stats declared as StatsLoggerModifier and TypeFieldDescription(package private) final StatsLoggerNullStatsProvider.nullStatsLoggerprotected final StatsLoggerCachingStatsLogger.underlyingFields in org.apache.bookkeeper.stats with type parameters of type StatsLoggerModifier and TypeFieldDescriptionprotected final ConcurrentMap<String,StatsLogger> CachingStatsLogger.scopeStatsLoggersprotected final ConcurrentMap<String,StatsLogger> CachingStatsProvider.statsLoggersMethods in org.apache.bookkeeper.stats that return StatsLoggerModifier and TypeMethodDescriptionCachingStatsProvider.getStatsLogger(String scope) NullStatsProvider.getStatsLogger(String scope) StatsProvider.getStatsLogger(String scope) Return the stats logger to a given scope.Provide the stats logger under scope name.default StatsLoggerStatsLogger.scopeLabel(String labelName, String labelValue) Provide the stats logger with an attached label.Methods in org.apache.bookkeeper.stats with parameters of type StatsLoggerModifier and TypeMethodDescriptionvoidCachingStatsLogger.removeScope(String name, StatsLogger statsLogger) voidNullStatsLogger.removeScope(String name, StatsLogger statsLogger) voidStatsLogger.removeScope(String name, StatsLogger statsLogger) Remove the given statsLogger for scope name.Constructors in org.apache.bookkeeper.stats with parameters of type StatsLoggerModifierConstructorDescriptionAlertStatsLogger(StatsLogger globalStatsLogger, String alertStatName) AlertStatsLogger(StatsLogger globalStatsLogger, String scope, String alertStatName) CachingStatsLogger(StatsLogger statsLogger) -
Uses of StatsLogger in org.apache.bookkeeper.stats.codahale
Classes in org.apache.bookkeeper.stats.codahale that implement StatsLoggerModifier and TypeClassDescriptionclassAStatsLoggerimplemented based on Codahale metrics library.classAStatsLoggerimplemented based on Codahale metrics library.Methods in org.apache.bookkeeper.stats.codahale that return StatsLoggerModifier and TypeMethodDescriptionCodahaleMetricsProvider.getStatsLogger(String name) FastCodahaleMetricsProvider.getStatsLogger(String name) Methods in org.apache.bookkeeper.stats.codahale with parameters of type StatsLoggerModifier and TypeMethodDescriptionvoidCodahaleStatsLogger.removeScope(String name, StatsLogger statsLogger) -
Uses of StatsLogger in org.apache.bookkeeper.stats.otel
Classes in org.apache.bookkeeper.stats.otel that implement StatsLoggerMethods in org.apache.bookkeeper.stats.otel that return StatsLoggerModifier and TypeMethodDescriptionOtelMetricsProvider.getStatsLogger(String scope) OtelStatsLogger.scopeLabel(String labelName, String labelValue) Methods in org.apache.bookkeeper.stats.otel with parameters of type StatsLoggerModifier and TypeMethodDescriptionvoidOtelStatsLogger.removeScope(String name, StatsLogger statsLogger) -
Uses of StatsLogger in org.apache.bookkeeper.stats.prometheus
Classes in org.apache.bookkeeper.stats.prometheus that implement StatsLoggerMethods in org.apache.bookkeeper.stats.prometheus that return StatsLoggerModifier and TypeMethodDescriptionPrometheusMetricsProvider.getStatsLogger(String scope) PrometheusStatsLogger.scopeLabel(String labelName, String labelValue) Methods in org.apache.bookkeeper.stats.prometheus with parameters of type StatsLoggerModifier and TypeMethodDescriptionvoidPrometheusStatsLogger.removeScope(String name, StatsLogger statsLogger) -
Uses of StatsLogger in org.apache.bookkeeper.zookeeper
Fields in org.apache.bookkeeper.zookeeper declared as StatsLoggerModifier and TypeFieldDescription(package private) StatsLoggerZooKeeperClient.Builder.statsLoggerMethods in org.apache.bookkeeper.zookeeper with parameters of type StatsLoggerConstructors in org.apache.bookkeeper.zookeeper with parameters of type StatsLoggerModifierConstructorDescriptionprotectedZooKeeperClient(String connectString, int sessionTimeoutMs, ZooKeeperWatcherBase watcherManager, RetryPolicy connectRetryPolicy, RetryPolicy operationRetryPolicy, StatsLogger statsLogger, int retryExecThreadCount, double rate, boolean allowReadOnlyMode) ZooKeeperWatcherBase(int zkSessionTimeOut, boolean allowReadOnlyMode, Set<org.apache.zookeeper.Watcher> childWatchers, StatsLogger statsLogger) ZooKeeperWatcherBase(int zkSessionTimeOut, boolean allowReadOnlyMode, StatsLogger statsLogger)
BookKeeper.Builder.statsLogger(StatsLogger)