Package | Description |
---|---|
org.apache.zookeeper.server.quorum | |
org.apache.zookeeper.server.quorum.flexible |
Modifier and Type | Method and Description |
---|---|
protected QuorumPeer.QuorumServer |
Learner.findLeader()
Returns the address of the node we think is the leader.
|
Modifier and Type | Method and Description |
---|---|
Map<Long,QuorumPeer.QuorumServer> |
QuorumPeer.getObservingView()
Returns only observers, no followers.
|
Map<Long,QuorumPeer.QuorumServer> |
QuorumPeerConfig.getServers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumPeer.getView()
A 'view' is a node's current opinion of the membership of the entire
ensemble.
|
Map<Long,QuorumPeer.QuorumServer> |
QuorumPeer.getVotingView()
Observers are not contained in this view, only nodes with
PeerType=PARTICIPANT.
|
Modifier and Type | Method and Description |
---|---|
void |
QuorumPeer.QuorumServer.checkAddressDuplicate(QuorumPeer.QuorumServer s) |
void |
RemotePeerBean.setQuorumServer(QuorumPeer.QuorumServer peer) |
Modifier and Type | Method and Description |
---|---|
protected static int |
QuorumPeer.countParticipants(Map<Long,QuorumPeer.QuorumServer> peers)
Count the number of nodes in the map that could be followers.
|
Constructor and Description |
---|
RemotePeerBean(QuorumPeer localPeer,
QuorumPeer.QuorumServer peer) |
Constructor and Description |
---|
QuorumCnxManager(QuorumPeer self,
long mySid,
Map<Long,QuorumPeer.QuorumServer> view,
QuorumAuthServer authServer,
QuorumAuthLearner authLearner,
int socketTimeout,
boolean listenOnAllIPs,
int quorumCnxnThreadsSize,
boolean quorumSaslAuthEnabled) |
QuorumPeer(Map<Long,QuorumPeer.QuorumServer> quorumPeers,
File snapDir,
File logDir,
int clientPort,
int electionAlg,
long myid,
int tickTime,
int initLimit,
int syncLimit)
This constructor is only used by the existing unit test code.
|
QuorumPeer(Map<Long,QuorumPeer.QuorumServer> quorumPeers,
File snapDir,
File logDir,
int clientPort,
int electionAlg,
long myid,
int tickTime,
int initLimit,
int syncLimit,
QuorumVerifier quorumConfig)
This constructor is only used by the existing unit test code.
|
QuorumPeer(Map<Long,QuorumPeer.QuorumServer> quorumPeers,
File dataDir,
File dataLogDir,
int electionType,
long myid,
int tickTime,
int initLimit,
int syncLimit,
boolean quorumListenOnAllIPs,
ServerCnxnFactory cnxnFactory,
QuorumVerifier quorumConfig) |
QuorumPeer(Map<Long,QuorumPeer.QuorumServer> quorumPeers,
File dataDir,
File dataLogDir,
int electionType,
long myid,
int tickTime,
int initLimit,
int syncLimit,
ServerCnxnFactory cnxnFactory)
For backward compatibility purposes, we instantiate QuorumMaj by default.
|
Modifier and Type | Method and Description |
---|---|
Map<Long,QuorumPeer.QuorumServer> |
QuorumMaj.getAllMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumHierarchical.getAllMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumVerifier.getAllMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumMaj.getObservingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumHierarchical.getObservingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumVerifier.getObservingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumMaj.getVotingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumHierarchical.getVotingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumVerifier.getVotingMembers() |
Constructor and Description |
---|
QuorumMaj(Map<Long,QuorumPeer.QuorumServer> allMembers)
Defines a majority to avoid computing it every time.
|
Copyright © 2008–2019 The Apache Software Foundation. All rights reserved.