Uses of Interface
org.apache.bookkeeper.meta.LedgerManager
Packages that use LedgerManager
Package
Description
Provides a Bookie server that stores entries for clients.
Package of the classes for defining bookie stats.
Classes related to DB based ledger storage.
BookKeeper Client.
Classes for interacting with bookkeeper ledgers and ledger metadata.
Classes for replicating Bookkeeper data.
-
Uses of LedgerManager in org.apache.bookkeeper.bookie
Methods in org.apache.bookkeeper.bookie with parameters of type LedgerManagerModifier and TypeMethodDescriptionstatic LedgerStorageBookieResources.createLedgerStorage(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator) 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.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) Constructors in org.apache.bookkeeper.bookie with parameters of type LedgerManagerModifierConstructorDescriptionGarbageCollectorThread(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.ScanAndCompareGarbageCollector(LedgerManager ledgerManager, CompactableLedgerStorage ledgerStorage, ServerConfiguration conf, StatsLogger statsLogger) -
Uses of LedgerManager in org.apache.bookkeeper.bookie.datainteg
Constructors in org.apache.bookkeeper.bookie.datainteg with parameters of type LedgerManagerModifierConstructorDescriptionDataIntegrityCheckImpl(BookieId bookieId, LedgerManager ledgerManager, LedgerStorage ledgerStorage, EntryCopier entryCopier, BookKeeperAdmin admin, io.reactivex.rxjava3.core.Scheduler scheduler) (package private)MetadataAsyncIterator(io.reactivex.rxjava3.core.Scheduler scheduler, LedgerManager ledgerManager, int maxInFlight, int zkTimeout, TimeUnit zkTimeoutUnit) -
Uses of LedgerManager in org.apache.bookkeeper.bookie.storage.ldb
Methods in org.apache.bookkeeper.bookie.storage.ldb with parameters of type LedgerManagerModifier 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 LedgerManagerModifierConstructorDescriptionSingleDirectoryDbLedgerStorage(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 LedgerManager in org.apache.bookkeeper.client
Fields in org.apache.bookkeeper.client declared as LedgerManagerModifier and TypeFieldDescription(package private) final LedgerManagerBookKeeper.ledgerManager(package private) final LedgerManagerLedgerFragmentReplicator.SingleFragmentCallback.ledgerManagerMethods in org.apache.bookkeeper.client that return LedgerManagerModifier and TypeMethodDescriptionBookKeeper.getLedgerManager()Returns ref to speculative read counter, needed in PendingReadOp.ClientContext.getLedgerManager()(package private) LedgerManagerBookKeeper.getUnderlyingLedgerManager()Methods in org.apache.bookkeeper.client with parameters of type LedgerManagerModifier and TypeMethodDescriptionstatic booleanBookKeeperAdmin.areEntriesOfLedgerStoredInTheBookie(long ledgerId, BookieId bookieAddress, LedgerManager ledgerManager) Constructors in org.apache.bookkeeper.client with parameters of type LedgerManagerModifierConstructorDescription(package private)MetadataUpdateLoop(LedgerManager lm, long ledgerId, Supplier<Versioned<LedgerMetadata>> currentLocalValue, MetadataUpdateLoop.NeedsUpdatePredicate needsTransformation, MetadataUpdateLoop.MetadataTransform transform, MetadataUpdateLoop.LocalValueUpdater updateLocalValue) (package private)MetadataUpdateLoop(LedgerManager lm, long ledgerId, Supplier<Versioned<LedgerMetadata>> currentLocalValue, MetadataUpdateLoop.NeedsUpdatePredicate needsTransformation, MetadataUpdateLoop.MetadataTransform transform, MetadataUpdateLoop.LocalValueUpdater updateLocalValue, com.google.common.util.concurrent.RateLimiter throttler) Construct the loop.(package private)SingleFragmentCallback(org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentsMcb, LedgerHandle lh, LedgerManager ledgerManager, long fragmentStartId, Map<BookieId, BookieId> oldBookie2NewBookie) -
Uses of LedgerManager in org.apache.bookkeeper.meta
Classes in org.apache.bookkeeper.meta that implement LedgerManagerModifier and TypeClassDescriptionclassAn abstract class for managing hierarchical ledgers.classAbstract ledger manager based on zookeeper, which provides common methods such as query zk nodes.classA ledger manager that cleans up resources upon closing.(package private) classManage all ledgers in a single zk node.(package private) classHierarchicalLedgerManager makes use of both LongHierarchicalLedgerManager and LegacyHierarchicalLedgerManager to extend the 31-bit ledger id range of the LegacyHierarchicalLedgerManager to that of the LongHierarchicalLedgerManager while remaining backwards-compatible with the legacy manager.(package private) classHierarchical Ledger Manager which manages ledger meta in zookeeper using 2-level hierarchical znodes.(package private) classLongHierarchical Ledger Manager which manages ledger meta in zookeeper using 5-level hierarchical znodes.(package private) static classDeprecated.static classA no-op implementation of LedgerManager.Methods in org.apache.bookkeeper.meta that return LedgerManagerModifier and TypeMethodDescriptionCleanupLedgerManager.getUnderlying()FlatLedgerManagerFactory.newLedgerManager()Deprecated.HierarchicalLedgerManagerFactory.newLedgerManager()LedgerManagerFactory.newLedgerManager()return ledger manager for client-side to manage ledger metadata.LegacyHierarchicalLedgerManagerFactory.newLedgerManager()LongHierarchicalLedgerManagerFactory.newLedgerManager()MSLedgerManagerFactory.newLedgerManager()Deprecated.NullMetadataBookieDriver.NullLedgerManagerFactory.newLedgerManager()Constructors in org.apache.bookkeeper.meta with parameters of type LedgerManager -
Uses of LedgerManager in org.apache.bookkeeper.replication
Fields in org.apache.bookkeeper.replication declared as LedgerManagerConstructors in org.apache.bookkeeper.replication with parameters of type LedgerManagerModifierConstructorDescriptionAuditorBookieCheckTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BookieLedgerIndexer bookieLedgerIndexer, BiConsumer<AtomicBoolean, Throwable> hasAuditCheckTask, BiConsumer<Void, Throwable> submitCheckTask) (package private)AuditorCheckAllLedgersTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BiConsumer<AtomicBoolean, Throwable> hasAuditCheckTask) (package private)AuditorPlacementPolicyCheckTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BiConsumer<AtomicBoolean, Throwable> hasAuditCheckTask) (package private)AuditorReplicasCheckTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BiConsumer<AtomicBoolean, Throwable> hasAuditCheckTask) (package private)AuditorTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BiConsumer<AtomicBoolean, Throwable> hasAuditCheckTask) BookieLedgerIndexer(LedgerManager ledgerManager)