Package org.apache.bookkeeper.bookie.storage.ldb

Class LedgerMetadataIndex

java.lang.Object

org.apache.bookkeeper.bookie.storage.ldb.LedgerMetadataIndex

All Implemented Interfaces:

Closeable, AutoCloseable

public class LedgerMetadataIndex
extends Object
implements Closeable

Maintains an index for the ledgers metadata.

The key is the ledgerId and the value is the DbLedgerStorageDataFormats.LedgerData content.

Constructor Summary

Constructors

Constructor	Description
LedgerMetadataIndex(ServerConfiguration conf, KeyValueStorageFactory storageFactory, String basePath, StatsLogger stats)

Method Summary

Modifier and Type	Method	Description
boolean	clearLimbo(long ledgerId)
void	close()
void	delete(long ledgerId)
void	flush()	Flushes all pending changes.
DbLedgerStorageDataFormats.LedgerData	get(long ledgerId)
Iterable<Long>	getActiveLedgersInRange(long firstLedgerId, long lastLedgerId)
(package private) int	getStorageStateFlags()
void	removeDeletedLedgers()
void	set(long ledgerId, DbLedgerStorageDataFormats.LedgerData ledgerData)
(package private) void	setExplicitLac(long ledgerId, io.netty.buffer.ByteBuf lac)
boolean	setFenced(long ledgerId)
boolean	setLimbo(long ledgerId)
void	setMasterKey(long ledgerId, byte[] masterKey)
(package private) boolean	setStorageStateFlags(int expected, int newFlags)

Methods inherited from class java.lang.Object

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

Constructor Details

LedgerMetadataIndex

public LedgerMetadataIndex(ServerConfiguration conf,
 KeyValueStorageFactory storageFactory,
 String basePath,
 StatsLogger stats)
                    throws IOException

Throws:

IOException

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

get

public DbLedgerStorageDataFormats.LedgerData get(long ledgerId)
                                          throws IOException

Throws:

IOException

set

public void set(long ledgerId,
 DbLedgerStorageDataFormats.LedgerData ledgerData)
         throws IOException

Throws:

IOException

delete

public void delete(long ledgerId)
            throws IOException

Throws:

IOException

getActiveLedgersInRange

public Iterable<Long> getActiveLedgersInRange(long firstLedgerId,
 long lastLedgerId)
                                       throws IOException

Throws:

IOException

setFenced

public boolean setFenced(long ledgerId)
                  throws IOException

Throws:

IOException

setLimbo

public boolean setLimbo(long ledgerId)
                 throws IOException

Throws:

IOException

clearLimbo

public boolean clearLimbo(long ledgerId)
                   throws IOException

Throws:

IOException

setMasterKey

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

Throws:

IOException

flush

public void flush()
           throws IOException

Flushes all pending changes.

Throws:

IOException

removeDeletedLedgers

public void removeDeletedLedgers()
                          throws IOException

Throws:

IOException

getStorageStateFlags

int getStorageStateFlags()
                  throws IOException

Throws:

IOException

setStorageStateFlags

boolean setStorageStateFlags(int expected,
 int newFlags)
                      throws IOException

Throws:

IOException

setExplicitLac

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

Throws:

IOException