| AsyncCallback.AddCallback |
Async Callback for adding entries to ledgers.
|
| AsyncCallback.AddCallbackWithLatency |
Async Callback for adding entries to ledgers with latency information.
|
| AsyncCallback.AddLacCallback |
Async Callback for updating LAC for ledgers.
|
| AsyncCallback.CloseCallback |
Async Callback for closing ledgers.
|
| AsyncCallback.CreateCallback |
Async Callback for creating ledgers.
|
| AsyncCallback.DeleteCallback |
Async Callback for deleting ledgers.
|
| AsyncCallback.IsClosedCallback |
Async Callback for checking if a ledger is closed.
|
| AsyncCallback.OpenCallback |
Async Callback for opening ledgers.
|
| AsyncCallback.ReadCallback |
Async Callback for reading entries from ledgers.
|
| AsyncCallback.ReadLastConfirmedAndEntryCallback |
Async Callback for long polling read request.
|
| AsyncCallback.ReadLastConfirmedCallback |
Async Callback for reading LAC for ledgers.
|
| AsyncCallback.RecoverCallback |
Async Callback for recovering ledgers.
|
| BatchedReadOp.BatchedLedgerEntryRequest |
|
| BKException |
Class the enumerates all the possible error conditions.
|
| BKException.BKNotEnoughBookiesException |
Bookkeeper not enough bookies exception.
|
| BookieInfoReader |
|
| BookieInfoReader.BookieInfo |
A class represents the information (e.g.
|
| BookieInfoReader.State |
Tracks whether there is an execution in progress as well as whether
another is pending.
|
| BookiesHealthInfo |
This interface returns heuristics used to determine the health of a Bookkeeper server for read
ordering.
|
| BookieWatcher |
Watch for Bookkeeper cluster status.
|
| BookieWatcherImpl |
This class is responsible for maintaining a consistent view of what bookies
are available by reading Zookeeper (and setting watches on the bookie nodes).
|
| BookKeeper |
BookKeeper client.
|
| BookKeeper.Builder |
BookKeeper Client Builder to build client instances.
|
| BookKeeper.DigestType |
There are 3 digest types that can be used for verification.
|
| BookKeeperAdmin |
Admin client for BookKeeper clusters.
|
| BookKeeperClientStats |
List of constants for defining client stats names.
|
| ClientContext |
Collection of client objects used by LedgerHandle to interact with
the outside world.
|
| ClientInternalConf |
|
| DistributionSchedule |
This interface determines how entries are distributed among bookies.
|
| DistributionSchedule.AckSet |
An ack set represents the set of bookies from which
a response must be received so that an entry can be
considered to be replicated on a quorum.
|
| DistributionSchedule.QuorumCoverageSet |
Interface to keep track of which bookies in an ensemble, an action
has been performed for.
|
| DistributionSchedule.WriteSet |
A write set represents the set of bookies to which
a request will be written.
|
| EnsemblePlacementPolicy |
EnsemblePlacementPolicy encapsulates the algorithm that bookkeeper client uses to select a number of bookies
from the cluster as an ensemble for storing entries. |
| EnsemblePlacementPolicy.PlacementPolicyAdherence |
enum for PlacementPolicyAdherence.
|
| EnsemblePlacementPolicy.PlacementResult |
Result of a placement calculation against a placement policy.
|
| ExplicitLacFlushPolicy |
|
| ITopologyAwareEnsemblePlacementPolicy |
Interface for topology aware ensemble placement policy.
|
| ITopologyAwareEnsemblePlacementPolicy.Ensemble |
Ensemble used to hold the result of an ensemble selected for placement.
|
| ITopologyAwareEnsemblePlacementPolicy.Predicate |
Predicate used when choosing an ensemble.
|
| LedgerEntry |
Ledger entry.
|
| LedgerFragment |
Represents the entries of a segment of a ledger which are stored on subset of
bookies in the segments bookie ensemble.
|
| LedgerFragment.ReplicateType |
ReplicateType.
|
| LedgerFragmentReplicator.Throttler |
|
| LedgerHandle |
Ledger handle contains ledger metadata and is used to access the read and
write operations to a ledger.
|
| LedgerHandle.NoopCloseCallback |
|
| LedgerHandleAdv |
Ledger Advanced handle extends LedgerHandle to provide API to add entries with
user supplied entryIds. |
| LedgerMetadataBuilder |
Builder for building LedgerMetadata objects.
|
| LedgerRecoveryOp |
This class encapsulated the ledger recovery operation.
|
| ListenerBasedPendingReadOp |
|
| MetadataUpdateLoop.LocalValueUpdater |
|
| MetadataUpdateLoop.MetadataTransform |
|
| MetadataUpdateLoop.NeedsUpdatePredicate |
|
| PendingAddOp |
This represents a pending add operation.
|
| PendingReadLacOp.LacCallback |
|
| PendingReadOp |
Sequence of entries of a ledger that represents a pending read operation.
|
| PendingReadOp.SingleLedgerEntryRequest |
|
| RackawareEnsemblePlacementPolicy |
A placement policy implementation use rack information for placing ensembles.
|
| RackawareEnsemblePlacementPolicyImpl |
Simple rackware ensemble placement policy.
|
| ReadLastConfirmedAndEntryOp |
Long poll read operation.
|
| ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback |
Wrapper to get all recovered data from the request.
|
| ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest |
|
| ReadLastConfirmedOp.LastConfirmedDataCallback |
Wrapper to get all recovered data from the request.
|
| ReadOnlyLedgerHandle |
Read only ledger handle.
|
| ReadOpBase |
|
| ReadOpBase.LedgerEntryRequest |
|
| RegionAwareEnsemblePlacementPolicy |
A placement policy use region information in the network topology for placing ensembles.
|
| SpeculativeRequestExecutionPolicy |
Define a policy for speculative request execution.
|
| SpeculativeRequestExecutor |
Define an executor for issuing speculative requests.
|
| SyncCallbackUtils.LastAddConfirmedCallback |
|
| TopologyAwareEnsemblePlacementPolicy |
|
| TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints |
|
| TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble |
A predicate checking the rack coverage for write quorum in RoundRobinDistributionSchedule,
which ensures that a write quorum should be covered by at least two racks. |
| TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet |
|
| TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet |
|
| TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet |
|
| TopologyAwareEnsemblePlacementPolicy.TruePredicate |
|
| WeightedRandomSelection |
|
| WeightedRandomSelection.WeightedObject |
|
| ZoneawareEnsemblePlacementPolicyImpl |
Simple zoneaware ensemble placement policy.
|
| ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation |
Zone and UpgradeDomain pair of a node.
|