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.
|
QuorumPeer.QuorumServer |
Observer.getCurrentLearnerMaster() |
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,
int connectToLearnerMasterLimit)
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,
int connectToLearnerMasterLimit,
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,
int connectToLearnerMasterLimit,
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,
int connectToLearnerMasterLimit,
ServerCnxnFactory cnxnFactory)
For backward compatibility purposes, we instantiate QuorumMaj by default.
|
Modifier and Type | Method and Description |
---|---|
Map<Long,QuorumPeer.QuorumServer> |
QuorumVerifier.getAllMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumHierarchical.getAllMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumMaj.getAllMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumVerifier.getObservingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumHierarchical.getObservingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumMaj.getObservingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumVerifier.getVotingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumHierarchical.getVotingMembers() |
Map<Long,QuorumPeer.QuorumServer> |
QuorumMaj.getVotingMembers() |
Constructor and Description |
---|
QuorumMaj(Map<Long,QuorumPeer.QuorumServer> allMembers)
Defines a majority to avoid computing it every time.
|
Copyright © 2008–2021 The Apache Software Foundation. All rights reserved.