Package org.apache.bookkeeper.proto
package org.apache.bookkeeper.proto
Classes related to the Bookkeeper protocol.
-
ClassDescriptionBookie Server Stats.A read view of stats, also used in CompositeViewData to expose to JMX.Operation Statistics.Maps a logical BookieId to a ResolvedBookieSocketAddress that it to a network address.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.Low level client for talking to bookies.Implements the client-side part of the BookKeeper protocol.Represents the connection to a BookKeeper client, from the Bookie side.Netty server for serving bookie requests.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.A response that adds data.An authentication request.A response with an authentication message.The request for reading data with batch optimization.The response for batched read.An error response.The first int of a packet is the header.This is similar to add request, but it used when processing the request on the bookie side.A Request that reads data.A request that reads data.A Bookie request object.A response object.A class for encoding and decoding the Bookkeeper protocol.An encoder/decoder interface for the Bookkeeper protocol.A request message decoder.A request message encoder.An encoder/decoder for the Bookkeeper protocol before version 3.A request encoder/decoder for the Bookkeeper protocol version 3.A response message decoder.A response message encoder.A response encoder/decoder for the Bookkeeper protocol before version 3.A response encoder/decoder for the Bookkeeper protocol version 3.Serverside handler for bookkeeper requests.An implementation of the RequestProcessor interface.Implements the server-side part of the BookKeeper protocol.Declaration of a callback interfaces used in bookkeeper client library but not exposed to the client application.Declaration of a callback implementation for calls from BookieClient objects.Force callback interface.Future for GetListOfEntriesOfLedger.A generic callback interface.Generic callback future.This is a callback interface for fetching metadata about a bookie.A callback interface for GetListOfEntriesOfLedger command.Listener on ledger metadata changes.This is a multi callback object that waits for all of the multiple async operations to complete.Processor to process a specific element.Declaration of a callback implementation for calls from BookieClient objects.Declaration of a callback interface for the Last Add Confirmed context of a reader.Listener on entries responded.A last-add-confirmed (LAC) reader callback interface.A callback interface for a STARTTLS command.A callback implementation with an internal timer.A writer callback interface.A last-add-confirmed (LAC) writer callback interface.Protobuf type
AddRequestProtobuf typeAddRequestProtobuf enumAddRequest.FlagProtobuf typeAddResponseProtobuf typeAddResponseProtobuf typeAuthMessageProtobuf typeAuthMessage* Packet header for all requests.* Packet header for all requests.Protobuf typeContextPairProtobuf typeContextPairProtobuf typeForceLedgerRequestProtobuf typeForceLedgerRequestProtobuf typeForceLedgerResponseProtobuf typeForceLedgerResponseProtobuf typeGetBookieInfoRequestProtobuf typeGetBookieInfoRequestProtobuf enumGetBookieInfoRequest.FlagsProtobuf typeGetBookieInfoResponseProtobuf typeGetBookieInfoResponseProtobuf typeGetListOfEntriesOfLedgerRequestProtobuf typeGetListOfEntriesOfLedgerRequestProtobuf typeGetListOfEntriesOfLedgerResponseProtobuf typeGetListOfEntriesOfLedgerResponse* Supported operations by this protocol.* Protocol Versions.Protobuf typeReadLacRequestProtobuf typeReadLacRequestProtobuf typeReadLacResponseProtobuf typeReadLacResponseProtobuf typeReadRequestProtobuf typeReadRequestProtobuf enumReadRequest.FlagProtobuf typeReadResponseProtobuf typeReadResponseProtobuf typeRequestProtobuf typeRequestProtobuf typeResponseProtobuf typeResponseProtobuf typeStartTLSRequestProtobuf typeStartTLSRequestProtobuf typeStartTLSResponseProtobuf typeStartTLSResponse* Status codes.Protobuf typeWriteLacRequestProtobuf typeWriteLacRequestProtobuf typeWriteLacResponseProtobuf typeWriteLacResponseRepresents the connection to a Bookie, from the client side.Represents the connection to a BookKeeper client, from the Bookie side.* Debug information for auditor votes* Debug information for auditor votes* information about services exposed by a Bookie.* information about services exposed by a Bookie.* Information about an endpoint.* Information about an endpoint.* information of checkAllLedgers execution* information of checkAllLedgers execution* Cookie format for storing cookie information* Cookie format for storing cookie information* Metadata format for storing ledger information* Metadata format for storing ledger informationProtobuf typeLedgerMetadataFormat.cMetadataMapEntryProtobuf typeLedgerMetadataFormat.cMetadataMapEntryProtobuf enumLedgerMetadataFormat.DigestTypeProtobuf typeLedgerMetadataFormat.SegmentProtobuf typeLedgerMetadataFormat.SegmentProtobuf enumLedgerMetadataFormat.StateProtobuf typeLedgerRereplicationLayoutFormatProtobuf typeLedgerRereplicationLayoutFormat* Debug information for locks* Debug information for locks* information of PlacementPolicyCheck execution* information of PlacementPolicyCheck execution* information of ReplicasCheck execution* information of ReplicasCheck executionProtobuf typeUnderreplicatedLedgerFormatProtobuf typeUnderreplicatedLedgerFormatProvide a simple round-robin style channel pool.A processor class for v3 bookie metadata packets.A processor class for v3 entries of a ledger packets.Local registry for embedded Bookies.Processor handling long poll read entry request.PacketProcessorBase<T extends BookieProtocol.Request>A base class for bookeeper packet processors.A base class for bookkeeper protocol v3 packet processors.This class manages all details of connection to a particular bookie.Decorator to preserve MDC for connection listener.Factory to createPerChannelBookieClient.An interface to manage channel pooling for bookie client.A read processor for v3 last add confirmed messages.ABookkeeperInternalCallbacks.ReadEntryCallbackCtxfor long poll read requests.A umbrella class for request related stats.Utilities for requests.Simple Implementation of BookieServiceInfo supplier.Processes add entry requests.