Package org.apache.bookkeeper.proto
Classes related to the Bookkeeper protocol.
-
Interface Summary Interface Description BookieAddressResolver Maps a logical BookieId to a ResolvedBookieSocketAddress that it to a network address.BookieClient Low level client for talking to bookies.BookieConnectionPeer Represents the connection to a BookKeeper client, from the Bookie side.BookieProtocol The packets of the Bookie protocol all have a 4-byte integer indicating the type of request or response at the very beginning of the packet followed by a payload.BookieProtoEncoding.EnDecoder An encoder/decoder interface for the Bookkeeper protocol.BookkeeperInternalCallbacks.ForceLedgerCallback Force callback interface.BookkeeperInternalCallbacks.GenericCallback<T> A generic callback interface.BookkeeperInternalCallbacks.GetBookieInfoCallback This is a callback interface for fetching metadata about a bookie.BookkeeperInternalCallbacks.GetListOfEntriesOfLedgerCallback A callback interface for GetListOfEntriesOfLedger command.BookkeeperInternalCallbacks.LedgerMetadataListener Listener on ledger metadata changes.BookkeeperInternalCallbacks.Processor<T> Processor to process a specific element.BookkeeperInternalCallbacks.ReadEntryCallback Declaration of a callback implementation for calls from BookieClient objects.BookkeeperInternalCallbacks.ReadEntryCallbackCtx Declaration of a callback interface for the Last Add Confirmed context of a reader.BookkeeperInternalCallbacks.ReadEntryListener Listener on entries responded.BookkeeperInternalCallbacks.ReadLacCallback A last-add-confirmed (LAC) reader callback interface.BookkeeperInternalCallbacks.StartTLSCallback A callback interface for a STARTTLS command.BookkeeperInternalCallbacks.WriteCallback A writer callback interface.BookkeeperInternalCallbacks.WriteLacCallback A last-add-confirmed (LAC) writer callback interface.ClientConnectionPeer Represents the connection to a Bookie, from the client side.ConnectionPeer Represents the connection to a BookKeeper client, from the Bookie side.PerChannelBookieClientFactory Factory to createPerChannelBookieClient
.PerChannelBookieClientPool An interface to manage channel pooling for bookie client. -
Class Summary Class Description AuthHandler AuthHandler.ClientSideHandler AuthHandler.ServerSideHandler AuthHandler.ServerSideHandler.AuthResponseCallback AuthHandler.ServerSideHandler.AuthResponseCallbackLegacy BKStats Bookie Server Stats.BKStats.OpStatData A read view of stats, also used in CompositeViewData to expose to JMX.BKStats.OpStats Operation Statistics.BookieClientImpl Implements the client-side part of the BookKeeper protocol.BookieNettyServer Netty server for serving bookie requests.BookieProtocol.AddRequest A Request that adds data.BookieProtocol.AddResponse A response that adds data.BookieProtocol.AuthRequest An authentication request.BookieProtocol.AuthResponse A response with an authentication message.BookieProtocol.ErrorResponse An error response.BookieProtocol.PacketHeader The first int of a packet is the header.BookieProtocol.ParsedAddRequest This is similar to add request, but it used when processing the request on the bookie side.BookieProtocol.ReadRequest A Request that reads data.BookieProtocol.ReadResponse A request that reads data.BookieProtocol.Request A Bookie request object.BookieProtocol.Response A response object.BookieProtoEncoding A class for encoding and decoding the Bookkeeper protocol.BookieProtoEncoding.RequestDecoder A request message decoder.BookieProtoEncoding.RequestEncoder A request message encoder.BookieProtoEncoding.RequestEnDeCoderPreV3 An encoder/decoder for the Bookkeeper protocol before version 3.BookieProtoEncoding.RequestEnDecoderV3 A request encoder/decoder for the Bookkeeper protocol version 3.BookieProtoEncoding.ResponseDecoder A response message decoder.BookieProtoEncoding.ResponseEncoder A response message encoder.BookieProtoEncoding.ResponseEnDeCoderPreV3 A response encoder/decoder for the Bookkeeper protocol before version 3.BookieProtoEncoding.ResponseEnDecoderV3 A response encoder/decoder for the Bookkeeper protocol version 3.BookieRequestHandler Serverside handler for bookkeeper requests.BookieRequestProcessor An implementation of the RequestProcessor interface.BookieServer Implements the server-side part of the BookKeeper protocol.BookkeeperInternalCallbacks Declaration of a callback interfaces used in bookkeeper client library but not exposed to the client application.BookkeeperInternalCallbacks.FutureGetListOfEntriesOfLedger Future for GetListOfEntriesOfLedger.BookkeeperInternalCallbacks.GenericCallbackFuture<T> Generic callback future.BookkeeperInternalCallbacks.MultiCallback This is a multi callback object that waits for all of the multiple async operations to complete.BookkeeperInternalCallbacks.TimedGenericCallback<T> A callback implementation with an internal timer.DefaultPerChannelBookieClientPool Provide a simple round-robin style channel pool.ForceLedgerProcessorV3 GetBookieInfoProcessorV3 A processor class for v3 bookie metadata packets.GetListOfEntriesOfLedgerProcessorV3 A processor class for v3 entries of a ledger packets.LocalBookiesRegistry Local registry for embedded Bookies.LongPollReadEntryProcessorV3 Processor handling long poll read entry request.PacketProcessorBase<T extends BookieProtocol.Request> A base class for bookeeper packet processors.PacketProcessorBaseV3 A base class for bookkeeper protocol v3 packet processors.PerChannelBookieClient This class manages all details of connection to a particular bookie.PerChannelBookieClient.ContextPreservingFutureListener Decorator to preserve MDC for connection listener.ReadEntryProcessor ReadEntryProcessorV3 ReadLacProcessorV3 A read processor for v3 last add confirmed messages.ReadLastConfirmedAndEntryContext ABookkeeperInternalCallbacks.ReadEntryCallbackCtx
for long poll read requests.RequestStats A umbrella class for request related stats.RequestUtils Utilities for requests.ResponseBuilder SimpleBookieServiceInfoProvider Simple Implementation of BookieServiceInfo supplier.WriteEntryProcessor Processes add entry requests.WriteEntryProcessorV3 WriteLacProcessorV3 -
Enum Summary Enum Description PerChannelBookieClient.ConnectionState -
Exception Summary Exception Description AuthHandler.AuthenticationException BookieAddressResolver.BookieIdNotResolvedException This error happens when there is not enough information to resolve a BookieId to a BookieSocketAddress, this can happen when the Bookie is down and it is not publishing its EndpointInfo.