Package org.apache.bookkeeper.bookie

Class LedgerDescriptor

java.lang.Object

org.apache.bookkeeper.bookie.LedgerDescriptor

Direct Known Subclasses:

LedgerDescriptorImpl

public abstract class LedgerDescriptor
extends Object

Implements a ledger inside a bookie. In particular, it implements operations to write entries to a ledger and read entries from a ledger.

Constructor Summary

Constructors

Constructor	Description
LedgerDescriptor()

Method Summary

Modifier and Type	Method	Description
(package private) abstract long	addEntry(io.netty.buffer.ByteBuf entry)
(package private) abstract void	cancelWaitForLastAddConfirmedUpdate(Watcher<LastAddConfirmedUpdateNotification> watcher)
(package private) abstract void	checkAccess(byte[] masterKey)
(package private) static LedgerDescriptor	create(byte[] masterKey, long ledgerId, LedgerStorage ledgerStorage)
(package private) static io.netty.buffer.ByteBuf	createLedgerFenceEntry(Long ledgerId)
(package private) static LedgerDescriptor	createReadOnly(long ledgerId, LedgerStorage ledgerStorage)
(package private) abstract CompletableFuture<Boolean>	fenceAndLogInJournal(Journal journal)	When we fence a ledger, we need to first set ledger to fenced state in memory and then log the fence entry in Journal so that we can rebuild the state.
(package private) abstract io.netty.buffer.ByteBuf	getExplicitLac()
(package private) abstract long	getLastAddConfirmed()
(package private) abstract long	getLedgerId()
(package private) abstract PrimitiveIterator.OfLong	getListOfEntriesOfLedger(long ledgerId)
(package private) abstract boolean	isFenced()
(package private) abstract io.netty.buffer.ByteBuf	readEntry(long entryId)
(package private) abstract void	setExplicitLac(io.netty.buffer.ByteBuf entry)
(package private) abstract boolean	setFenced()
(package private) abstract boolean	waitForLastAddConfirmedUpdate(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

LedgerDescriptor

public LedgerDescriptor()

Method Details

create

static LedgerDescriptor create(byte[] masterKey,
 long ledgerId,
 LedgerStorage ledgerStorage)
                        throws IOException

Throws:

IOException

createReadOnly

static LedgerDescriptor createReadOnly(long ledgerId,
 LedgerStorage ledgerStorage)
                                throws IOException,
Bookie.NoLedgerException

Throws:

IOException

Bookie.NoLedgerException

createLedgerFenceEntry

static io.netty.buffer.ByteBuf createLedgerFenceEntry(Long ledgerId)

checkAccess

abstract void checkAccess(byte[] masterKey)
                   throws BookieException,
IOException

Throws:

BookieException

IOException

getLedgerId

abstract long getLedgerId()

setFenced

abstract boolean setFenced()
                    throws IOException

Throws:

IOException

isFenced

abstract boolean isFenced()
                   throws IOException,
BookieException

Throws:

IOException

BookieException

fenceAndLogInJournal

abstract CompletableFuture<Boolean> fenceAndLogInJournal(Journal journal)
                                                  throws IOException

When we fence a ledger, we need to first set ledger to fenced state in memory and then log the fence entry in Journal so that we can rebuild the state.

We should satisfy the future only after we complete logging fence entry in Journal

Returns:

Throws:

IOException

addEntry

abstract long addEntry(io.netty.buffer.ByteBuf entry)
                throws IOException,
BookieException

Throws:

IOException

BookieException

readEntry

abstract io.netty.buffer.ByteBuf readEntry(long entryId)
                                    throws IOException,
BookieException

Throws:

IOException

BookieException

getLastAddConfirmed

abstract long getLastAddConfirmed()
                           throws IOException,
BookieException

Throws:

IOException

BookieException

waitForLastAddConfirmedUpdate

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

Throws:

IOException

cancelWaitForLastAddConfirmedUpdate

abstract void cancelWaitForLastAddConfirmedUpdate(Watcher<LastAddConfirmedUpdateNotification> watcher)
                                           throws IOException

Throws:

IOException

setExplicitLac

abstract void setExplicitLac(io.netty.buffer.ByteBuf entry)
                      throws IOException

Throws:

IOException

getExplicitLac

abstract io.netty.buffer.ByteBuf getExplicitLac()
                                         throws IOException,
BookieException

Throws:

IOException

BookieException

getListOfEntriesOfLedger

abstract PrimitiveIterator.OfLong getListOfEntriesOfLedger(long ledgerId)
                                                    throws IOException

Throws:

IOException