| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) ClientContext |
ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl.clientCtx |
(package private) ClientContext |
PendingReadOp.clientCtx |
(package private) ClientContext |
LedgerRecoveryOp.clientCtx |
(package private) ClientContext |
PendingWriteLacOp.clientCtx |
(package private) ClientContext |
PendingAddOp.clientCtx |
(package private) ClientContext |
LedgerHandle.clientCtx |
| Modifier and Type | Method and Description |
|---|---|
(package private) ClientContext |
BookKeeper.getClientCtx() |
| Modifier and Type | Method and Description |
|---|---|
(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) |
| Constructor and Description |
|---|
ExplicitLacFlushPolicyImpl(LedgerHandle lh,
ClientContext clientCtx) |
LedgerHandle(ClientContext clientCtx,
long ledgerId,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> versionedMetadata,
BookKeeper.DigestType digestType,
byte[] password,
java.util.EnumSet<WriteFlag> writeFlags) |
LedgerHandleAdv(ClientContext clientCtx,
long ledgerId,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> metadata,
BookKeeper.DigestType digestType,
byte[] password,
java.util.EnumSet<WriteFlag> writeFlags) |
LedgerRecoveryOp(LedgerHandle lh,
ClientContext clientCtx) |
ListenerBasedPendingReadOp(LedgerHandle lh,
ClientContext clientCtx,
long startEntryId,
long endEntryId,
org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener listener,
java.lang.Object ctx,
boolean isRecoveryRead) |
PendingReadOp(LedgerHandle lh,
ClientContext clientCtx,
long startEntryId,
long endEntryId,
boolean isRecoveryRead) |
PendingWriteLacOp(LedgerHandle lh,
ClientContext clientCtx,
java.util.List<org.apache.bookkeeper.net.BookieId> ensemble,
AsyncCallback.AddLacCallback cb,
java.lang.Object ctx) |
ReadLastConfirmedAndEntryOp(LedgerHandle lh,
ClientContext clientCtx,
java.util.List<org.apache.bookkeeper.net.BookieId> ensemble,
ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback cb,
long prevEntryId,
long timeOutInMillis) |
ReadOnlyLedgerHandle(ClientContext clientCtx,
long ledgerId,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> metadata,
BookKeeper.DigestType digestType,
byte[] password,
boolean watch) |
RecoveryReadOp(LedgerHandle lh,
ClientContext clientCtx,
long startEntryId,
long endEntryId,
org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener cb,
java.lang.Object ctx) |
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.