| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| Modifier and Type | Interface and Description |
|---|---|
static interface |
AsyncCallback.AddCallback
Async Callback for adding entries to ledgers.
|
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
LedgerRecoveryOp
This class encapsulated the ledger recovery operation.
|
(package private) static class |
SyncCallbackUtils.SyncAddCallback |
| Modifier and Type | Field and Description |
|---|---|
(package private) AsyncCallback.AddCallbackWithLatency |
PendingAddOp.cb |
| Modifier and Type | Method and Description |
|---|---|
void |
LedgerHandleAdv.asyncAddEntry(long entryId,
byte[] data,
int offset,
int length,
AsyncCallback.AddCallbackWithLatency cb,
java.lang.Object ctx)
Add entry asynchronously to an open ledger, using an offset and range.
|
void |
LedgerHandle.asyncAddEntry(long entryId,
byte[] data,
int offset,
int length,
AsyncCallback.AddCallbackWithLatency cb,
java.lang.Object ctx)
Add entry asynchronously to an open ledger, using an offset and range.
|
void |
LedgerHandleAdv.asyncAddEntry(long entryId,
io.netty.buffer.ByteBuf data,
AsyncCallback.AddCallbackWithLatency cb,
java.lang.Object ctx)
Add entry asynchronously to an open ledger, using an offset and range.
|
void |
LedgerHandle.asyncAddEntry(long entryId,
io.netty.buffer.ByteBuf data,
AsyncCallback.AddCallbackWithLatency cb,
java.lang.Object ctx)
Add entry asynchronously to an open ledger, using an offset and range.
|
(package private) static PendingAddOp |
PendingAddOp.create(LedgerHandle lh,
ClientContext clientCtx,
java.util.List<org.apache.bookkeeper.net.BookieId> ensemble,
io.netty.buffer.ByteBuf payload,
java.util.EnumSet<WriteFlag> writeFlags,
AsyncCallback.AddCallbackWithLatency cb,
java.lang.Object ctx) |
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.