| BufferStats |
Provides live statistics about Jute buffer usage in term of proposal and client request size.
|
| CommitProcessor |
This RequestProcessor matches the incoming committed requests with the
locally submitted requests.
|
| FastLeaderElection |
Implementation of leader election using TCP.
|
| FastLeaderElection.Notification |
Notifications are messages that let other peers know that
a given peer has changed its vote, either because it has
joined leader election or because it learned of another
peer with higher zxid or same zxid and higher server id
|
| FastLeaderElection.ToSend |
Messages that a peer wants to send to other peers.
|
| Follower |
This class has the control logic for the Follower.
|
| FollowerBean |
Follower MBean interface implementation
|
| FollowerRequestProcessor |
This RequestProcessor forwards any requests that modify the state of the
system to the Leader.
|
| FollowerZooKeeperServer |
Just like the standard ZooKeeperServer.
|
| Leader |
This class has the control logic for the Leader.
|
| Leader.Proposal |
|
| Leader.PureRequestProposal |
|
| LeaderBean |
Leader MBean interface implementation.
|
| LeaderElectionBean |
Leader election MBean interface implementation
|
| LeaderRequestProcessor |
Responsible for performing local session upgrade.
|
| LeaderSessionTracker |
The leader session tracker tracks local and global sessions on the leader.
|
| LeaderZooKeeperServer |
Just like the standard ZooKeeperServer.
|
| Learner |
This class is the superclass of two of the three main actors in a ZK
ensemble: Followers and Observers.
|
| LearnerHandler |
There will be an instance of this class created by the Leader for each
learner.
|
| LearnerHandlerBean |
|
| LearnerMaster |
interface for keeping Observers in sync
|
| LearnerSender |
|
| LearnerSessionTracker |
The learner session tracker is used by learners (followers and observers) to
track zookeeper sessions which may or may not be echoed to the leader.
|
| LearnerSyncRequest |
|
| LearnerSyncThrottler |
Utility class to limit the number of concurrent syncs from a leader to
observers and followers or from a follower to observers.
|
| LearnerZooKeeperServer |
Parent class for all ZooKeeperServers for Learners
|
| LocalPeerBean |
Implementation of the local peer MBean interface.
|
| LocalSessionTracker |
Local session tracker.
|
| MultipleAddresses |
This class allows to store several quorum and electing addresses.
|
| Observer |
Observers are peers that do not take part in the atomic broadcast protocol.
|
| ObserverMaster |
Used by Followers to host Observers.
|
| ObserverRequestProcessor |
This RequestProcessor forwards any requests that modify the state of the
system to the Leader.
|
| ObserverZooKeeperServer |
A ZooKeeperServer for the Observer node type.
|
| PrependableSocket |
|
| ProposalRequestProcessor |
This RequestProcessor simply forwards requests to an AckRequestProcessor and
SyncRequestProcessor.
|
| QuorumBean |
|
| QuorumCnxManager |
This class implements a connection manager for leader election using TCP.
|
| QuorumCnxManager.InitialMessage |
|
| QuorumCnxManager.Message |
|
| QuorumPeer |
This class manages the quorum protocol.
|
| QuorumPeer.AddressTuple |
|
| QuorumPeer.QuorumServer |
|
| QuorumPeerConfig |
|
| QuorumPeerMain |
Configuration file
|
| QuorumStats |
|
| QuorumZooKeeperServer |
Abstract base class for all ZooKeeperServers that participate in
a quorum.
|
| ReadOnlyBean |
ReadOnly MX Bean interface, implemented by ReadOnlyBean
|
| ReadOnlyRequestProcessor |
This processor is at the beginning of the ReadOnlyZooKeeperServer's
processors chain.
|
| ReadOnlyZooKeeperServer |
A ZooKeeperServer which comes into play when peer is partitioned from the
majority.
|
| RemotePeerBean |
A remote peer bean only provides limited information about the remote peer,
and the peer cannot be managed remotely.
|
| SendAckRequestProcessor |
|
| ServerBean |
An abstract base class for the leader and follower MBeans.
|
| StateSummary |
This class encapsulates the state comparison logic.
|
| SyncedLearnerTracker |
|
| SyncedLearnerTracker.QuorumVerifierAcksetPair |
|
| UnifiedServerSocket |
A ServerSocket that can act either as a regular ServerSocket, as a SSLServerSocket, or as both, depending on
the constructor parameters and on the type of client (TLS or plaintext) that connects to it.
|
| UnifiedServerSocket.UnifiedSocket |
The result of calling accept() on a UnifiedServerSocket.
|
| UpgradeableSessionTracker |
A session tracker that supports upgradeable local sessions.
|
| Vote |
|