Package org.apache.bookkeeper.verifier
Interface BookkeeperVerifier.BookkeeperDriver
-
- All Known Implementing Classes:
DirectBookkeeperDriver
- Enclosing class:
- BookkeeperVerifier
public static interface BookkeeperVerifier.BookkeeperDriver
Provides an interface for translating test operations into operations on a cluster.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
BookkeeperVerifier.BookkeeperDriver.ReadCallback
Callback for reads.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
closeLedger(long ledgerID, java.util.function.Consumer<java.lang.Integer> cb)
void
createLedger(long ledgerID, int enSize, int writeQSize, int ackQSize, java.util.function.Consumer<java.lang.Integer> cb)
void
deleteLedger(long ledgerID, java.util.function.Consumer<java.lang.Integer> cb)
void
readEntries(long ledgerID, long firstEntryID, long lastEntryID, java.util.function.BiConsumer<java.lang.Integer,java.util.ArrayList<byte[]>> cb)
void
writeEntry(long ledgerID, long entryID, byte[] data, java.util.function.Consumer<java.lang.Integer> cb)
-
-
-
Method Detail
-
createLedger
void createLedger(long ledgerID, int enSize, int writeQSize, int ackQSize, java.util.function.Consumer<java.lang.Integer> cb)
-
closeLedger
void closeLedger(long ledgerID, java.util.function.Consumer<java.lang.Integer> cb)
-
deleteLedger
void deleteLedger(long ledgerID, java.util.function.Consumer<java.lang.Integer> cb)
-
writeEntry
void writeEntry(long ledgerID, long entryID, byte[] data, java.util.function.Consumer<java.lang.Integer> cb)
-
readEntries
void readEntries(long ledgerID, long firstEntryID, long lastEntryID, java.util.function.BiConsumer<java.lang.Integer,java.util.ArrayList<byte[]>> cb)
-
-