Package org.apache.bookkeeper.meta

Class CleanupLedgerManager

java.lang.Object

org.apache.bookkeeper.meta.CleanupLedgerManager

All Implemented Interfaces:

Closeable, AutoCloseable, LedgerManager

public class CleanupLedgerManager
extends Object
implements LedgerManager

A ledger manager that cleans up resources upon closing.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.bookkeeper.meta.LedgerManager

LedgerManager.LedgerRange, LedgerManager.LedgerRangeIterator

Constructor Summary

Constructors

Constructor	Description
CleanupLedgerManager(LedgerManager lm)

Method Summary

Modifier and Type	Method	Description
void	asyncProcessLedgers(BookkeeperInternalCallbacks.Processor<Long> processor, org.apache.zookeeper.AsyncCallback.VoidCallback finalCb, Object context, int successRc, int failureRc)	Loop to process all ledgers.
void	close()
CompletableFuture<Versioned<LedgerMetadata>>	createLedgerMetadata(long lid, LedgerMetadata metadata)	Create a new ledger with provided ledger id and metadata.
(package private) int	getCurrentFuturePromiseSize()
LedgerManager.LedgerRangeIterator	getLedgerRanges(long zkOpTimeoutMs)	Loop to scan a range of metadata from metadata storage.
LedgerManager	getUnderlying()
CompletableFuture<Versioned<LedgerMetadata>>	readLedgerMetadata(long ledgerId)	Read ledger metadata of a specified ledger.
void	registerLedgerMetadataListener(long ledgerId, BookkeeperInternalCallbacks.LedgerMetadataListener listener)	Register the ledger metadata listener on ledgerId.
CompletableFuture<Void>	removeLedgerMetadata(long ledgerId, Version version)	Remove a specified ledger metadata by ledgerId and version.
void	unregisterLedgerMetadataListener(long ledgerId, BookkeeperInternalCallbacks.LedgerMetadataListener listener)	Unregister the ledger metadata listener on ledgerId.
CompletableFuture<Versioned<LedgerMetadata>>	writeLedgerMetadata(long ledgerId, LedgerMetadata metadata, Version currentVersion)	Write ledger metadata.

Methods inherited from class java.lang.Object

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

Constructor Details

CleanupLedgerManager

public CleanupLedgerManager(LedgerManager lm)

Method Details

getUnderlying

public LedgerManager getUnderlying()

registerLedgerMetadataListener

public void registerLedgerMetadataListener(long ledgerId,
 BookkeeperInternalCallbacks.LedgerMetadataListener listener)

Description copied from interface: LedgerManager

Register the ledger metadata listener on ledgerId.

Specified by:

registerLedgerMetadataListener in interface LedgerManager

Parameters:

ledgerId - ledger id.

listener - listener.

unregisterLedgerMetadataListener

public void unregisterLedgerMetadataListener(long ledgerId,
 BookkeeperInternalCallbacks.LedgerMetadataListener listener)

Description copied from interface: LedgerManager

Unregister the ledger metadata listener on ledgerId.

Specified by:

unregisterLedgerMetadataListener in interface LedgerManager

Parameters:

ledgerId - ledger id.

listener - ledger metadata listener.

getCurrentFuturePromiseSize

int getCurrentFuturePromiseSize()

createLedgerMetadata

public CompletableFuture<Versioned<LedgerMetadata>> createLedgerMetadata(long lid,
 LedgerMetadata metadata)

Description copied from interface: LedgerManager

Create a new ledger with provided ledger id and metadata.

Specified by:

createLedgerMetadata in interface LedgerManager

Parameters:

lid - Ledger id provided to be created

metadata - Metadata provided when creating the new ledger

Returns:

Future which, when completed returns the metadata of the newly created ledger. Completed with an exception:

• BKException.BKLedgerExistException if given ledger id exist
• BKException.ZKException /BKException.BKMetadataSerializationException for other issues

removeLedgerMetadata

public CompletableFuture<Void> removeLedgerMetadata(long ledgerId,
 Version version)

Description copied from interface: LedgerManager

Remove a specified ledger metadata by ledgerId and version.

Specified by:

removeLedgerMetadata in interface LedgerManager

Parameters:

ledgerId - Ledger Id

version - Ledger metadata version

Returns:

Future which, when completed, denotes that the ledger metadata has been removed. Completed with an exception:

• BKException.BKMetadataVersionException if version doesn't match
• BKException.BKNoSuchLedgerExistsOnMetadataServerException if ledger not exist
• BKException.ZKException for other issues

readLedgerMetadata

public CompletableFuture<Versioned<LedgerMetadata>> readLedgerMetadata(long ledgerId)

Description copied from interface: LedgerManager

Read ledger metadata of a specified ledger.

Specified by:

readLedgerMetadata in interface LedgerManager

Parameters:

ledgerId - Ledger Id

Returns:

Future which, when completed, contains the requested versioned metadata. Completed with an exception::

• BKException.BKNoSuchLedgerExistsOnMetadataServerException if ledger not exist
• BKException.ZKException for other issues

writeLedgerMetadata

public CompletableFuture<Versioned<LedgerMetadata>> writeLedgerMetadata(long ledgerId,
 LedgerMetadata metadata,
 Version currentVersion)

Description copied from interface: LedgerManager

Write ledger metadata.

Specified by:

writeLedgerMetadata in interface LedgerManager

Parameters:

ledgerId - Ledger Id

metadata - Ledger Metadata to write

currentVersion - The version of the metadata we expect to be overwriting.

Returns:

Future which, when completed, contains the newly written metadata. Completed with an exception:

• BKException.BKMetadataVersionException if version in metadata doesn't match
• BKException.ZKException for other issue

asyncProcessLedgers

public void asyncProcessLedgers(BookkeeperInternalCallbacks.Processor<Long> processor,
 org.apache.zookeeper.AsyncCallback.VoidCallback finalCb,
 Object context,
 int successRc,
 int failureRc)

Description copied from interface: LedgerManager

Loop to process all ledgers.

After all ledgers were processed, finalCb will be triggered:
• if all ledgers are processed done with OK, success rc will be passed to finalCb.
• if some ledgers are processed failed, failure rc will be passed to finalCb.

Specified by:

asyncProcessLedgers in interface LedgerManager

Parameters:

processor - Ledger Processor to process a specific ledger

finalCb - Callback triggered after all ledgers are processed

context - Context of final callback

successRc - Success RC code passed to finalCb when callback

failureRc - Failure RC code passed to finalCb when exceptions occurred.

getLedgerRanges

public LedgerManager.LedgerRangeIterator getLedgerRanges(long zkOpTimeoutMs)

Description copied from interface: LedgerManager

Loop to scan a range of metadata from metadata storage.

Specified by:

getLedgerRanges in interface LedgerManager

Parameters:

zkOpTimeoutMs - Iterator considers timeout while fetching ledger-range from zk.

Returns:

will return a iterator of the Ranges

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException