Uses of Interface
org.apache.bookkeeper.meta.LedgerManager
-
Packages that use LedgerManager 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.storage.ldb Classes related to DB based ledger storage.org.apache.bookkeeper.client BookKeeper Client.org.apache.bookkeeper.meta Classes for interacting with bookkeeper ledgers and ledger metadata.org.apache.bookkeeper.replication Classes for replicating Bookkeeper data. -
-
Uses of LedgerManager in org.apache.bookkeeper.bookie
Methods in org.apache.bookkeeper.bookie with parameters of type LedgerManager Modifier and Type Method Description static LedgerStorage
BookieResources. createLedgerStorage(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
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.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)
Constructors in org.apache.bookkeeper.bookie with parameters of type LedgerManager Constructor Description 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.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 LedgerManager Constructor Description DataIntegrityCheckImpl(BookieId bookieId, LedgerManager ledgerManager, LedgerStorage ledgerStorage, EntryCopier entryCopier, BookKeeperAdmin admin, io.reactivex.rxjava3.core.Scheduler scheduler)
MetadataAsyncIterator(io.reactivex.rxjava3.core.Scheduler scheduler, LedgerManager ledgerManager, int maxInFlight, int zkTimeout, java.util.concurrent.TimeUnit zkTimeoutUnit)
-
Uses of LedgerManager in org.apache.bookkeeper.bookie.storage.ldb
Methods in org.apache.bookkeeper.bookie.storage.ldb with parameters of type LedgerManager 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 LedgerManager Constructor Description 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 LedgerManager in org.apache.bookkeeper.client
Fields in org.apache.bookkeeper.client declared as LedgerManager Modifier and Type Field Description (package private) LedgerManager
BookKeeper. ledgerManager
(package private) LedgerManager
LedgerFragmentReplicator.SingleFragmentCallback. ledgerManager
Methods in org.apache.bookkeeper.client that return LedgerManager Modifier and Type Method Description LedgerManager
BookKeeper. getLedgerManager()
Returns ref to speculative read counter, needed in PendingReadOp.LedgerManager
ClientContext. getLedgerManager()
(package private) LedgerManager
BookKeeper. getUnderlyingLedgerManager()
Methods in org.apache.bookkeeper.client with parameters of type LedgerManager Modifier and Type Method Description static boolean
BookKeeperAdmin. areEntriesOfLedgerStoredInTheBookie(long ledgerId, BookieId bookieAddress, LedgerManager ledgerManager)
Constructors in org.apache.bookkeeper.client with parameters of type LedgerManager Constructor Description MetadataUpdateLoop(LedgerManager lm, long ledgerId, java.util.function.Supplier<Versioned<LedgerMetadata>> currentLocalValue, MetadataUpdateLoop.NeedsUpdatePredicate needsTransformation, MetadataUpdateLoop.MetadataTransform transform, MetadataUpdateLoop.LocalValueUpdater updateLocalValue)
MetadataUpdateLoop(LedgerManager lm, long ledgerId, java.util.function.Supplier<Versioned<LedgerMetadata>> currentLocalValue, MetadataUpdateLoop.NeedsUpdatePredicate needsTransformation, MetadataUpdateLoop.MetadataTransform transform, MetadataUpdateLoop.LocalValueUpdater updateLocalValue, com.google.common.util.concurrent.RateLimiter throttler)
Construct the loop.SingleFragmentCallback(org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentsMcb, LedgerHandle lh, LedgerManager ledgerManager, long fragmentStartId, java.util.Map<BookieId,BookieId> oldBookie2NewBookie)
-
Uses of LedgerManager in org.apache.bookkeeper.meta
Classes in org.apache.bookkeeper.meta that implement LedgerManager Modifier and Type Class Description class
AbstractHierarchicalLedgerManager
An abstract class for managing hierarchical ledgers.class
AbstractZkLedgerManager
Abstract ledger manager based on zookeeper, which provides common methods such as query zk nodes.class
CleanupLedgerManager
A ledger manager that cleans up resources upon closing.(package private) class
FlatLedgerManager
Manage all ledgers in a single zk node.(package private) class
HierarchicalLedgerManager
HierarchicalLedgerManager 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) class
LegacyHierarchicalLedgerManager
Hierarchical Ledger Manager which manages ledger meta in zookeeper using 2-level hierarchical znodes.(package private) class
LongHierarchicalLedgerManager
LongHierarchical Ledger Manager which manages ledger meta in zookeeper using 5-level hierarchical znodes.(package private) static class
MSLedgerManagerFactory.MsLedgerManager
Deprecated.static class
NullMetadataBookieDriver.NullLedgerManager
A no-op implementation of LedgerManager.Methods in org.apache.bookkeeper.meta that return LedgerManager Modifier and Type Method Description LedgerManager
CleanupLedgerManager. getUnderlying()
LedgerManager
FlatLedgerManagerFactory. newLedgerManager()
Deprecated.LedgerManager
HierarchicalLedgerManagerFactory. newLedgerManager()
LedgerManager
LedgerManagerFactory. newLedgerManager()
return ledger manager for client-side to manage ledger metadata.LedgerManager
LegacyHierarchicalLedgerManagerFactory. newLedgerManager()
LedgerManager
LongHierarchicalLedgerManagerFactory. newLedgerManager()
LedgerManager
MSLedgerManagerFactory. newLedgerManager()
Deprecated.LedgerManager
NullMetadataBookieDriver.NullLedgerManagerFactory. newLedgerManager()
Constructors in org.apache.bookkeeper.meta with parameters of type LedgerManager Constructor Description CleanupLedgerManager(LedgerManager lm)
-
Uses of LedgerManager in org.apache.bookkeeper.replication
Fields in org.apache.bookkeeper.replication declared as LedgerManager Modifier and Type Field Description protected LedgerManager
AuditorTask. ledgerManager
Constructors in org.apache.bookkeeper.replication with parameters of type LedgerManager Constructor Description AuditorBookieCheckTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BookieLedgerIndexer bookieLedgerIndexer, java.util.function.BiConsumer<java.util.concurrent.atomic.AtomicBoolean,java.lang.Throwable> hasAuditCheckTask, java.util.function.BiConsumer<java.lang.Void,java.lang.Throwable> submitCheckTask)
AuditorCheckAllLedgersTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, java.util.function.BiConsumer<java.util.concurrent.atomic.AtomicBoolean,java.lang.Throwable> hasAuditCheckTask)
AuditorPlacementPolicyCheckTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, java.util.function.BiConsumer<java.util.concurrent.atomic.AtomicBoolean,java.lang.Throwable> hasAuditCheckTask)
AuditorReplicasCheckTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, java.util.function.BiConsumer<java.util.concurrent.atomic.AtomicBoolean,java.lang.Throwable> hasAuditCheckTask)
AuditorTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, java.util.function.BiConsumer<java.util.concurrent.atomic.AtomicBoolean,java.lang.Throwable> hasAuditCheckTask)
BookieLedgerIndexer(LedgerManager ledgerManager)
-