Uses of Class
org.apache.bookkeeper.proto.BookieRequestHandler
Packages that use BookieRequestHandler
Package
Description
Provides a Bookie server that stores entries for clients.
Define the processors used by bookie from processing requests.
Classes related to the Bookkeeper protocol.
-
Uses of BookieRequestHandler in org.apache.bookkeeper.bookie
Method parameters in org.apache.bookkeeper.bookie with type arguments of type BookieRequestHandlerModifier and TypeMethodDescriptionintJournal.ForceWriteRequest.process(com.carrotsearch.hppc.ObjectHashSet<BookieRequestHandler> writeHandlers) -
Uses of BookieRequestHandler in org.apache.bookkeeper.processor
Methods in org.apache.bookkeeper.processor with parameters of type BookieRequestHandlerModifier and TypeMethodDescriptionvoidRequestProcessor.processRequest(Object r, BookieRequestHandler channel) Process request. -
Uses of BookieRequestHandler in org.apache.bookkeeper.proto
Fields in org.apache.bookkeeper.proto declared as BookieRequestHandlerModifier and TypeFieldDescription(package private) BookieRequestHandlerPacketProcessorBase.requestHandler(package private) final BookieRequestHandlerPacketProcessorBaseV3.requestHandlerMethods in org.apache.bookkeeper.proto with parameters of type BookieRequestHandlerModifier and TypeMethodDescriptionstatic BatchedReadEntryProcessorBatchedReadEntryProcessor.create(BookieProtocol.BatchedReadRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, ExecutorService fenceThreadPool, boolean throttleReadResponses, long maxBatchReadSize) static ReadEntryProcessorReadEntryProcessor.create(BookieProtocol.ReadRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, ExecutorService fenceThreadPool, boolean throttleReadResponses) static WriteEntryProcessorWriteEntryProcessor.create(BookieProtocol.ParsedAddRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor) protected voidPacketProcessorBase.init(T request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor) voidBookieRequestProcessor.processRequest(Object msg, BookieRequestHandler requestHandler) Constructors in org.apache.bookkeeper.proto with parameters of type BookieRequestHandlerModifierConstructorDescriptionForceLedgerProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor) GetBookieInfoProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor) GetListOfEntriesOfLedgerProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor) (package private)LongPollReadEntryProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, ExecutorService fenceThreadPool, ExecutorService longPollThreadPool, io.netty.util.HashedWheelTimer requestTimer) PacketProcessorBaseV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor) ReadEntryProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, ExecutorService fenceThreadPool) ReadLacProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor) WriteEntryProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor) WriteLacProcessorV3(BookkeeperProtocol.Request request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor)