Package org.apache.bookkeeper.bookie

Class BookieResources

java.lang.Object

org.apache.bookkeeper.bookie.BookieResources

public class BookieResources
extends Object

Centralizes the creation of injected resources.

Constructor Summary

Constructors

Constructor	Description
BookieResources()

Method Summary

Modifier and Type	Method	Description
static ByteBufAllocatorWithOomHandler	createAllocator(ServerConfiguration conf)
static DiskChecker	createDiskChecker(ServerConfiguration conf)
static LedgerDirsManager	createIndexDirsManager(ServerConfiguration conf, DiskChecker diskChecker, StatsLogger statsLogger, LedgerDirsManager fallback)
static LedgerDirsManager	createLedgerDirsManager(ServerConfiguration conf, DiskChecker diskChecker, StatsLogger statsLogger)
static LedgerStorage	createLedgerStorage(ServerConfiguration conf, LedgerManager ledgerManager, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator)
static MetadataBookieDriver	createMetadataDriver(ServerConfiguration conf, StatsLogger statsLogger)	Instantiate the metadata driver for the Bookie.

Methods inherited from class java.lang.Object

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

Constructor Details

BookieResources

public BookieResources()

Method Details

createMetadataDriver

public static MetadataBookieDriver createMetadataDriver(ServerConfiguration conf,
 StatsLogger statsLogger)
                                                 throws BookieException

Instantiate the metadata driver for the Bookie.

Throws:

BookieException

createAllocator

public static ByteBufAllocatorWithOomHandler createAllocator(ServerConfiguration conf)

createDiskChecker

public static DiskChecker createDiskChecker(ServerConfiguration conf)

createLedgerDirsManager

public static LedgerDirsManager createLedgerDirsManager(ServerConfiguration conf,
 DiskChecker diskChecker,
 StatsLogger statsLogger)
                                                 throws IOException

Throws:

IOException

createIndexDirsManager

public static LedgerDirsManager createIndexDirsManager(ServerConfiguration conf,
 DiskChecker diskChecker,
 StatsLogger statsLogger,
 LedgerDirsManager fallback)
                                                throws IOException

Throws:

IOException

createLedgerStorage

public static LedgerStorage createLedgerStorage(ServerConfiguration conf,
 LedgerManager ledgerManager,
 LedgerDirsManager ledgerDirsManager,
 LedgerDirsManager indexDirsManager,
 StatsLogger statsLogger,
 io.netty.buffer.ByteBufAllocator allocator)
                                         throws IOException

Throws:

IOException