Uses of Interface
org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback
-
Packages that use BookkeeperInternalCallbacks.GenericCallback Package Description org.apache.bookkeeper.client BookKeeper Client.org.apache.bookkeeper.meta Classes for interacting with bookkeeper ledgers and ledger metadata.org.apache.bookkeeper.proto Classes related to the Bookkeeper protocol.org.apache.bookkeeper.replication Classes for replicating Bookkeeper data.org.apache.bookkeeper.util Bookkeeper utilities. -
-
Uses of BookkeeperInternalCallbacks.GenericCallback in org.apache.bookkeeper.client
Methods in org.apache.bookkeeper.client with parameters of type BookkeeperInternalCallbacks.GenericCallback Modifier and Type Method Description void
BookKeeperAdmin. asyncGetLedgersContainBookies(java.util.Set<BookieId> bookies, BookkeeperInternalCallbacks.GenericCallback<java.util.SortedMap<java.lang.Long,LedgerMetadata>> callback)
void
LedgerChecker. checkLedger(LedgerHandle lh, BookkeeperInternalCallbacks.GenericCallback<java.util.Set<LedgerFragment>> cb)
Check that all the fragments in the passed in ledger, and report those which are missing.void
LedgerChecker. checkLedger(LedgerHandle lh, BookkeeperInternalCallbacks.GenericCallback<java.util.Set<LedgerFragment>> cb, long percentageOfLedgerFragmentToBeVerified)
(package private) void
ReadOnlyLedgerHandle. recover(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> finalCb)
(package private) void
ReadOnlyLedgerHandle. recover(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> finalCb, BookkeeperInternalCallbacks.ReadEntryListener listener, boolean forceRecovery)
Recover the ledger. -
Uses of BookkeeperInternalCallbacks.GenericCallback in org.apache.bookkeeper.meta
Methods in org.apache.bookkeeper.meta with parameters of type BookkeeperInternalCallbacks.GenericCallback Modifier and Type Method Description void
LedgerIdGenerator. generateLedgerId(BookkeeperInternalCallbacks.GenericCallback<java.lang.Long> cb)
Generate a global unique ledger id.void
LongZkLedgerIdGenerator. generateLedgerId(BookkeeperInternalCallbacks.GenericCallback<java.lang.Long> cb)
void
NullMetadataBookieDriver.NullLedgerIdGenerator. generateLedgerId(BookkeeperInternalCallbacks.GenericCallback<java.lang.Long> cb)
void
ZkLedgerIdGenerator. generateLedgerId(BookkeeperInternalCallbacks.GenericCallback<java.lang.Long> cb)
static void
ZkLedgerIdGenerator. generateLedgerIdImpl(BookkeeperInternalCallbacks.GenericCallback<java.lang.Long> cb, org.apache.zookeeper.ZooKeeper zk, java.lang.String ledgerPrefix, java.util.List<org.apache.zookeeper.data.ACL> zkAcls)
void
LedgerUnderreplicationManager. notifyLedgerReplicationEnabled(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
Receive notification asynchronously when the ledger replication process is enabled.void
NullMetadataBookieDriver.NullLedgerUnderreplicationManager. notifyLedgerReplicationEnabled(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
void
ZkLedgerUnderreplicationManager. notifyLedgerReplicationEnabled(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
void
LedgerUnderreplicationManager. notifyLostBookieRecoveryDelayChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
Receive notification asynchronously when the lostBookieRecoveryDelay value is Changed.void
NullMetadataBookieDriver.NullLedgerUnderreplicationManager. notifyLostBookieRecoveryDelayChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
void
ZkLedgerUnderreplicationManager. notifyLostBookieRecoveryDelayChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
default void
LedgerUnderreplicationManager. notifyUnderReplicationLedgerChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
Deprecated.void
NullMetadataBookieDriver.NullLedgerUnderreplicationManager. notifyUnderReplicationLedgerChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
void
ZkLedgerUnderreplicationManager. notifyUnderReplicationLedgerChanged(BookkeeperInternalCallbacks.GenericCallback<java.lang.Void> cb)
-
Uses of BookkeeperInternalCallbacks.GenericCallback in org.apache.bookkeeper.proto
Classes in org.apache.bookkeeper.proto that implement BookkeeperInternalCallbacks.GenericCallback Modifier and Type Class Description static class
BookkeeperInternalCallbacks.GenericCallbackFuture<T>
Generic callback future.static class
BookkeeperInternalCallbacks.TimedGenericCallback<T>
A callback implementation with an internal timer.(package private) class
DefaultPerChannelBookieClientPool
Provide a simple round-robin style channel pool.Fields in org.apache.bookkeeper.proto declared as BookkeeperInternalCallbacks.GenericCallback Modifier and Type Field Description (package private) BookkeeperInternalCallbacks.GenericCallback<T>
BookkeeperInternalCallbacks.TimedGenericCallback. cb
Methods in org.apache.bookkeeper.proto with parameters of type BookkeeperInternalCallbacks.GenericCallback Modifier and Type Method Description (package private) void
PerChannelBookieClient. connectIfNeededAndDoOp(BookkeeperInternalCallbacks.GenericCallback<PerChannelBookieClient> op)
void
DefaultPerChannelBookieClientPool. obtain(BookkeeperInternalCallbacks.GenericCallback<PerChannelBookieClient> callback, long key)
void
DefaultPerChannelBookieClientPool. obtain(BookkeeperInternalCallbacks.GenericCallback<PerChannelBookieClient> callback, long key, boolean forceUseV3)
void
PerChannelBookieClientPool. obtain(BookkeeperInternalCallbacks.GenericCallback<PerChannelBookieClient> callback, long key)
Obtain a channel from channel pool to execute operations.void
PerChannelBookieClientPool. obtain(BookkeeperInternalCallbacks.GenericCallback<PerChannelBookieClient> callback, long key, boolean forceUseV3)
Obtain a channel from channel pool by version to execute operations.Constructors in org.apache.bookkeeper.proto with parameters of type BookkeeperInternalCallbacks.GenericCallback Constructor Description TimedGenericCallback(BookkeeperInternalCallbacks.GenericCallback<T> cb, int successRc, OpStatsLogger statsLogger)
-
Uses of BookkeeperInternalCallbacks.GenericCallback in org.apache.bookkeeper.replication
Classes in org.apache.bookkeeper.replication that implement BookkeeperInternalCallbacks.GenericCallback Modifier and Type Class Description class
ReplicationEnableCb
Callback which is getting notified when the replication process is enabled. -
Uses of BookkeeperInternalCallbacks.GenericCallback in org.apache.bookkeeper.util
Classes in org.apache.bookkeeper.util that implement BookkeeperInternalCallbacks.GenericCallback Modifier and Type Class Description class
OrderedGenericCallback<T>
Generic callback implementation which will run the callback in the thread which matches the ordering key.Methods in org.apache.bookkeeper.util with parameters of type BookkeeperInternalCallbacks.GenericCallback Modifier and Type Method Description static void
ZkUtils. getChildrenInSingleNode(org.apache.zookeeper.ZooKeeper zk, java.lang.String node, BookkeeperInternalCallbacks.GenericCallback<java.util.List<java.lang.String>> cb)
Async get direct children under single node.
-