Package org.apache.bookkeeper.bookie
Class InterleavedStorageRegenerateIndexOp.DryRunLedgerCache
java.lang.Object
org.apache.bookkeeper.bookie.InterleavedStorageRegenerateIndexOp.DryRunLedgerCache
- All Implemented Interfaces:
Closeable,AutoCloseable,LedgerCache
- Enclosing class:
- InterleavedStorageRegenerateIndexOp
static class InterleavedStorageRegenerateIndexOp.DryRunLedgerCache
extends Object
implements LedgerCache
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.bookkeeper.bookie.LedgerCache
LedgerCache.LedgerIndexMetadata, LedgerCache.NoIndexForLedgerException, LedgerCache.PageEntries, LedgerCache.PageEntriesIterable -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidcancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher) voidclose()voiddeleteLedger(long ledgerId) voidflushLedger(boolean doAll) getEntriesIterator(long ledgerId) longgetEntryOffset(long ledger, long entry) io.netty.buffer.ByteBufgetExplicitLac(long ledgerId) getLastAddConfirmed(long ledgerId) longgetLastEntry(long ledgerId) booleanisFenced(long ledgerId) booleanledgerExists(long ledgerId) listEntries(long ledgerId) voidputEntryOffset(long ledger, long entry, long offset) readLedgerIndexMetadata(long ledgerId) byte[]readMasterKey(long ledgerId) voidsetExplicitLac(long ledgerId, io.netty.buffer.ByteBuf lac) booleansetFenced(long ledgerId) voidsetMasterKey(long ledgerId, byte[] masterKey) longupdateLastAddConfirmed(long ledgerId, long lac) booleanwaitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)
-
Constructor Details
-
DryRunLedgerCache
DryRunLedgerCache()
-
-
Method Details
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
setFenced
- Specified by:
setFencedin interfaceLedgerCache- Throws:
IOException
-
isFenced
- Specified by:
isFencedin interfaceLedgerCache- Throws:
IOException
-
setMasterKey
- Specified by:
setMasterKeyin interfaceLedgerCache- Throws:
IOException
-
readMasterKey
- Specified by:
readMasterKeyin interfaceLedgerCache- Throws:
IOExceptionBookieException
-
ledgerExists
- Specified by:
ledgerExistsin interfaceLedgerCache- Throws:
IOException
-
putEntryOffset
- Specified by:
putEntryOffsetin interfaceLedgerCache- Throws:
IOException
-
getEntryOffset
- Specified by:
getEntryOffsetin interfaceLedgerCache- Throws:
IOException
-
flushLedger
- Specified by:
flushLedgerin interfaceLedgerCache- Throws:
IOException
-
getLastEntry
- Specified by:
getLastEntryin interfaceLedgerCache- Throws:
IOException
-
getLastAddConfirmed
- Specified by:
getLastAddConfirmedin interfaceLedgerCache- Throws:
IOException
-
updateLastAddConfirmed
- Specified by:
updateLastAddConfirmedin interfaceLedgerCache- Throws:
IOException
-
waitForLastAddConfirmedUpdate
public boolean waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher) throws IOException - Specified by:
waitForLastAddConfirmedUpdatein interfaceLedgerCache- Throws:
IOException
-
cancelWaitForLastAddConfirmedUpdate
public void cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher) throws IOException - Specified by:
cancelWaitForLastAddConfirmedUpdatein interfaceLedgerCache- Throws:
IOException
-
deleteLedger
- Specified by:
deleteLedgerin interfaceLedgerCache- Throws:
IOException
-
setExplicitLac
- Specified by:
setExplicitLacin interfaceLedgerCache- Throws:
IOException
-
getExplicitLac
public io.netty.buffer.ByteBuf getExplicitLac(long ledgerId) - Specified by:
getExplicitLacin interfaceLedgerCache
-
listEntries
- Specified by:
listEntriesin interfaceLedgerCache- Throws:
IOException
-
readLedgerIndexMetadata
- Specified by:
readLedgerIndexMetadatain interfaceLedgerCache- Throws:
IOException
-
getEntriesIterator
- Specified by:
getEntriesIteratorin interfaceLedgerCache- Throws:
IOException
-