Package org.apache.bookkeeper.proto

Class BookkeeperInternalCallbacks

java.lang.Object

org.apache.bookkeeper.proto.BookkeeperInternalCallbacks

public class BookkeeperInternalCallbacks
extends Object

Declaration of a callback interfaces used in bookkeeper client library but not exposed to the client application.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BookkeeperInternalCallbacks.BatchedReadEntryCallback	Declaration of a callback implementation for calls from BookieClient objects.
static interface	BookkeeperInternalCallbacks.ForceLedgerCallback	Force callback interface.
static class	BookkeeperInternalCallbacks.FutureGetListOfEntriesOfLedger	Future for GetListOfEntriesOfLedger.
static interface	BookkeeperInternalCallbacks.GenericCallback<T>	A generic callback interface.
static class	BookkeeperInternalCallbacks.GenericCallbackFuture<T>	Generic callback future.
static interface	BookkeeperInternalCallbacks.GetBookieInfoCallback	This is a callback interface for fetching metadata about a bookie.
static interface	BookkeeperInternalCallbacks.GetListOfEntriesOfLedgerCallback	A callback interface for GetListOfEntriesOfLedger command.
static interface	BookkeeperInternalCallbacks.LedgerMetadataListener	Listener on ledger metadata changes.
static class	BookkeeperInternalCallbacks.MultiCallback	This is a multi callback object that waits for all of the multiple async operations to complete.
static interface	BookkeeperInternalCallbacks.Processor<T>	Processor to process a specific element.
static interface	BookkeeperInternalCallbacks.ReadEntryCallback	Declaration of a callback implementation for calls from BookieClient objects.
static interface	BookkeeperInternalCallbacks.ReadEntryCallbackCtx	Declaration of a callback interface for the Last Add Confirmed context of a reader.
static interface	BookkeeperInternalCallbacks.ReadEntryListener	Listener on entries responded.
static interface	BookkeeperInternalCallbacks.ReadLacCallback	A last-add-confirmed (LAC) reader callback interface.
static interface	BookkeeperInternalCallbacks.StartTLSCallback	A callback interface for a STARTTLS command.
static class	BookkeeperInternalCallbacks.TimedGenericCallback<T>	A callback implementation with an internal timer.
static interface	BookkeeperInternalCallbacks.WriteCallback	A writer callback interface.
static interface	BookkeeperInternalCallbacks.WriteLacCallback	A last-add-confirmed (LAC) writer callback interface.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
BookkeeperInternalCallbacks()

Method Summary

Modifier and Type	Method	Description
static <T> void	finish(int rc, T result, CompletableFuture<? super T> future)	Handle the Response Code and transform it to a BKException.

Methods inherited from class java.lang.Object

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

Field Details

LOG

static final org.slf4j.Logger LOG

Constructor Details

BookkeeperInternalCallbacks

public BookkeeperInternalCallbacks()

Method Details

finish

public static <T> void finish(int rc,
 T result,
 CompletableFuture<? super T> future)

Handle the Response Code and transform it to a BKException.

Type Parameters:

T -

Parameters:

rc -

result -

future -