Package org.apache.bookkeeper.verifier

Class DirectBookkeeperDriver

java.lang.Object

org.apache.bookkeeper.verifier.DirectBookkeeperDriver

All Implemented Interfaces:

BookkeeperVerifier.BookkeeperDriver

class DirectBookkeeperDriver
extends Object
implements BookkeeperVerifier.BookkeeperDriver

Driver for a normal Bookkeeper cluster.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.bookkeeper.verifier.BookkeeperVerifier.BookkeeperDriver

BookkeeperVerifier.BookkeeperDriver.ReadCallback

Constructor Summary

Constructors

Constructor	Description
DirectBookkeeperDriver(BookKeeper client)

Method Summary

Modifier and Type	Method	Description
void	closeLedger(long ledgerID, Consumer<Integer> cb)
void	createLedger(long ledgerID, int enSize, int writeQSize, int ackQSize, Consumer<Integer> cb)
void	deleteLedger(long ledgerID, Consumer<Integer> cb)
void	readEntries(long ledgerID, long firstEntryID, long lastEntryID, BiConsumer<Integer,ArrayList<byte[]>> cb)
void	writeEntry(long ledgerID, long entryID, byte[] data, Consumer<Integer> cb)

Methods inherited from class java.lang.Object

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

Constructor Details

DirectBookkeeperDriver

DirectBookkeeperDriver(BookKeeper client)

Method Details

createLedger

public void createLedger(long ledgerID,
 int enSize,
 int writeQSize,
 int ackQSize,
 Consumer<Integer> cb)

Specified by:

createLedger in interface BookkeeperVerifier.BookkeeperDriver

closeLedger

public void closeLedger(long ledgerID,
 Consumer<Integer> cb)

Specified by:

closeLedger in interface BookkeeperVerifier.BookkeeperDriver

deleteLedger

public void deleteLedger(long ledgerID,
 Consumer<Integer> cb)

Specified by:

deleteLedger in interface BookkeeperVerifier.BookkeeperDriver

writeEntry

public void writeEntry(long ledgerID,
 long entryID,
 byte[] data,
 Consumer<Integer> cb)

Specified by:

writeEntry in interface BookkeeperVerifier.BookkeeperDriver

readEntries

public void readEntries(long ledgerID,
 long firstEntryID,
 long lastEntryID,
 BiConsumer<Integer,ArrayList<byte[]>> cb)

Specified by:

readEntries in interface BookkeeperVerifier.BookkeeperDriver