Uses of Interface
org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.WriteCallback

Packages that use BookkeeperInternalCallbacks.WriteCallback

Package	Description
org.apache.bookkeeper.bookie	Provides a Bookie server that stores entries for clients.
org.apache.bookkeeper.client	BookKeeper Client.
org.apache.bookkeeper.proto	Classes related to the Bookkeeper protocol.

Uses of BookkeeperInternalCallbacks.WriteCallback in org.apache.bookkeeper.bookie

Classes in org.apache.bookkeeper.bookie that implement BookkeeperInternalCallbacks.WriteCallback

Modifier and Type	Class	Description
(package private) static class	BookieImpl.NopWriteCallback

Fields in org.apache.bookkeeper.bookie declared as BookkeeperInternalCallbacks.WriteCallback

Modifier and Type	Field	Description
(package private) BookkeeperInternalCallbacks.WriteCallback	Journal.QueueEntry.cb

Methods in org.apache.bookkeeper.bookie with parameters of type BookkeeperInternalCallbacks.WriteCallback

Modifier and Type	Method	Description
void	Bookie.addEntry(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, byte[] masterKey)
void	BookieImpl.addEntry(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, byte[] masterKey)	Add entry to a ledger.
(package private) static Journal.QueueEntry	Journal.QueueEntry.create(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, long ledgerId, long entryId, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, long enqueueTime, OpStatsLogger journalAddEntryStats, Counter callbackTime)
void	Bookie.forceLedger(long ledgerId, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx)
void	BookieImpl.forceLedger(long ledgerId, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx)	Force sync given 'ledgerId' entries on the journal to the disk.
(package private) void	Journal.forceLedger(long ledgerId, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx)
void	Journal.logAddEntry(long ledgerId, long entryId, io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx)
void	Journal.logAddEntry(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx)	record an add entry operation in journal.
void	Bookie.recoveryAddEntry(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, byte[] masterKey)
void	BookieImpl.recoveryAddEntry(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, byte[] masterKey)	Add entry to a ledger, even if the ledger has previous been fenced.
void	Bookie.setExplicitLac(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback writeCallback, Object ctx, byte[] masterKey)
void	BookieImpl.setExplicitLac(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback writeCallback, Object ctx, byte[] masterKey)

Uses of BookkeeperInternalCallbacks.WriteCallback in org.apache.bookkeeper.client

Classes in org.apache.bookkeeper.client that implement BookkeeperInternalCallbacks.WriteCallback

Modifier and Type	Class	Description
(package private) class	PendingAddOp	This represents a pending add operation.

Uses of BookkeeperInternalCallbacks.WriteCallback in org.apache.bookkeeper.proto

Classes in org.apache.bookkeeper.proto that implement BookkeeperInternalCallbacks.WriteCallback

Modifier and Type	Class	Description
(package private) class	AddCompletion
(package private) class	WriteEntryProcessor	Processes add entry requests.

Fields in org.apache.bookkeeper.proto declared as BookkeeperInternalCallbacks.WriteCallback

Modifier and Type	Field	Description
(package private) BookkeeperInternalCallbacks.WriteCallback	BookieClientImpl.ChannelReadyForAddEntryCallback.cb
(package private) BookkeeperInternalCallbacks.WriteCallback	AddCompletion.originalCallback

Methods in org.apache.bookkeeper.proto with parameters of type BookkeeperInternalCallbacks.WriteCallback

Modifier and Type	Method	Description
(package private) static AddCompletion	AddCompletion.acquireAddCompletion(CompletionKey key, BookkeeperInternalCallbacks.WriteCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient)
void	BookieClient.addEntry(BookieId address, long ledgerId, byte[] masterKey, long entryId, io.netty.util.ReferenceCounted toSend, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, int options, boolean allowFastFail, EnumSet<WriteFlag> writeFlags)	Add an entry for ledger ledgerId on the bookie at address address.
void	BookieClientImpl.addEntry(BookieId addr, long ledgerId, byte[] masterKey, long entryId, io.netty.util.ReferenceCounted toSend, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, int options, boolean allowFastFail, EnumSet<WriteFlag> writeFlags)
(package private) void	PerChannelBookieClient.addEntry(long ledgerId, byte[] masterKey, long entryId, io.netty.util.ReferenceCounted toSend, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, int options, boolean allowFastFail, EnumSet<WriteFlag> writeFlags)	This method should be called only after connection has been checked for PerChannelBookieClient.connectIfNeededAndDoOp(GenericCallback).
(package private) static BookieClientImpl.ChannelReadyForAddEntryCallback	BookieClientImpl.ChannelReadyForAddEntryCallback.create(BookieClientImpl bookieClient, io.netty.util.ReferenceCounted toSend, long ledgerId, long entryId, BookieId addr, Object ctx, BookkeeperInternalCallbacks.WriteCallback cb, int options, byte[] masterKey, boolean allowFastFail, EnumSet<WriteFlag> writeFlags)
(package private) void	AddCompletion.reset(CompletionKey key, BookkeeperInternalCallbacks.WriteCallback originalCallback, Object originalCtx, long ledgerId, long entryId, PerChannelBookieClient perChannelBookieClient)