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

Constructor	Description
DryRunLedgerCache()

Method Summary

Modifier and Type	Method	Description
void	cancelWaitForLastAddConfirmedUpdate(long ledgerId, Watcher<LastAddConfirmedUpdateNotification> watcher)
void	close()
void	deleteLedger(long ledgerId)
void	flushLedger(boolean doAll)
PrimitiveIterator.OfLong	getEntriesIterator(long ledgerId)
long	getEntryOffset(long ledger, long entry)
io.netty.buffer.ByteBuf	getExplicitLac(long ledgerId)
Long	getLastAddConfirmed(long ledgerId)
long	getLastEntry(long ledgerId)
boolean	isFenced(long ledgerId)
boolean	ledgerExists(long ledgerId)
LedgerCache.PageEntriesIterable	listEntries(long ledgerId)
void	putEntryOffset(long ledger, long entry, long offset)
LedgerCache.LedgerIndexMetadata	readLedgerIndexMetadata(long ledgerId)
byte[]	readMasterKey(long ledgerId)
void	setExplicitLac(long ledgerId, io.netty.buffer.ByteBuf lac)
boolean	setFenced(long ledgerId)
void	setMasterKey(long ledgerId, byte[] masterKey)
long	updateLastAddConfirmed(long ledgerId, long lac)
boolean	waitForLastAddConfirmedUpdate(long ledgerId, long previousLAC, Watcher<LastAddConfirmedUpdateNotification> watcher)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DryRunLedgerCache

DryRunLedgerCache()

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

setFenced

public boolean setFenced(long ledgerId)
                  throws IOException

Specified by:

setFenced in interface LedgerCache

Throws:

IOException

isFenced

public boolean isFenced(long ledgerId)
                 throws IOException

Specified by:

isFenced in interface LedgerCache

Throws:

IOException

setMasterKey

public void setMasterKey(long ledgerId,
 byte[] masterKey)
                  throws IOException

Specified by:

setMasterKey in interface LedgerCache

Throws:

IOException

readMasterKey

public byte[] readMasterKey(long ledgerId)
                     throws IOException,
BookieException

Specified by:

readMasterKey in interface LedgerCache

Throws:

IOException

BookieException

ledgerExists

public boolean ledgerExists(long ledgerId)
                     throws IOException

Specified by:

ledgerExists in interface LedgerCache

Throws:

IOException

putEntryOffset

public void putEntryOffset(long ledger,
 long entry,
 long offset)
                    throws IOException

Specified by:

putEntryOffset in interface LedgerCache

Throws:

IOException

getEntryOffset

public long getEntryOffset(long ledger,
 long entry)
                    throws IOException

Specified by:

getEntryOffset in interface LedgerCache

Throws:

IOException

flushLedger

public void flushLedger(boolean doAll)
                 throws IOException

Specified by:

flushLedger in interface LedgerCache

Throws:

IOException

getLastEntry

public long getLastEntry(long ledgerId)
                  throws IOException

Specified by:

getLastEntry in interface LedgerCache

Throws:

IOException

getLastAddConfirmed

public Long getLastAddConfirmed(long ledgerId)
                         throws IOException

Specified by:

getLastAddConfirmed in interface LedgerCache

Throws:

IOException

updateLastAddConfirmed

public long updateLastAddConfirmed(long ledgerId,
 long lac)
                            throws IOException

Specified by:

updateLastAddConfirmed in interface LedgerCache

Throws:

IOException

waitForLastAddConfirmedUpdate

public boolean waitForLastAddConfirmedUpdate(long ledgerId,
 long previousLAC,
 Watcher<LastAddConfirmedUpdateNotification> watcher)
                                      throws IOException

Specified by:

waitForLastAddConfirmedUpdate in interface LedgerCache

Throws:

IOException

cancelWaitForLastAddConfirmedUpdate

public void cancelWaitForLastAddConfirmedUpdate(long ledgerId,
 Watcher<LastAddConfirmedUpdateNotification> watcher)
                                         throws IOException

Specified by:

cancelWaitForLastAddConfirmedUpdate in interface LedgerCache

Throws:

IOException

deleteLedger

public void deleteLedger(long ledgerId)
                  throws IOException

Specified by:

deleteLedger in interface LedgerCache

Throws:

IOException

setExplicitLac

public void setExplicitLac(long ledgerId,
 io.netty.buffer.ByteBuf lac)
                    throws IOException

Specified by:

setExplicitLac in interface LedgerCache

Throws:

IOException

getExplicitLac

public io.netty.buffer.ByteBuf getExplicitLac(long ledgerId)

Specified by:

getExplicitLac in interface LedgerCache

listEntries

public LedgerCache.PageEntriesIterable listEntries(long ledgerId)
                                            throws IOException

Specified by:

listEntries in interface LedgerCache

Throws:

IOException

readLedgerIndexMetadata

public LedgerCache.LedgerIndexMetadata readLedgerIndexMetadata(long ledgerId)
                                                        throws IOException

Specified by:

readLedgerIndexMetadata in interface LedgerCache

Throws:

IOException

getEntriesIterator

public PrimitiveIterator.OfLong getEntriesIterator(long ledgerId)
                                            throws IOException

Specified by:

getEntriesIterator in interface LedgerCache

Throws:

IOException