Uses of Class
org.apache.zookeeper.server.quorum.QuorumPeer.QuorumServer
-
Packages that use QuorumPeer.QuorumServer Package Description org.apache.zookeeper.server.quorum -
-
Uses of QuorumPeer.QuorumServer in org.apache.zookeeper.server.quorum
Fields in org.apache.zookeeper.server.quorum with type parameters of type QuorumPeer.QuorumServer Modifier and Type Field Description protected java.util.HashMap<java.lang.Long,QuorumPeer.QuorumServer>
QuorumPeerConfig. observers
protected java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>
QuorumPeer. quorumPeers
The servers that make up the clusterprotected java.util.HashMap<java.lang.Long,QuorumPeer.QuorumServer>
QuorumPeerConfig. servers
Methods in org.apache.zookeeper.server.quorum that return QuorumPeer.QuorumServer Modifier and Type Method Description protected QuorumPeer.QuorumServer
Learner. findLeader()
Returns the address of the node we think is the leader.Methods in org.apache.zookeeper.server.quorum that return types with arguments of type QuorumPeer.QuorumServer Modifier and Type Method Description java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>
QuorumPeer. getObservingView()
Returns only observers, no followers.java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>
QuorumPeerConfig. getServers()
java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>
QuorumPeer. getView()
A 'view' is a node's current opinion of the membership of the entire ensemble.java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>
QuorumPeer. getVotingView()
Observers are not contained in this view, only nodes with PeerType=PARTICIPANT.Method parameters in org.apache.zookeeper.server.quorum with type arguments of type QuorumPeer.QuorumServer Modifier and Type Method Description protected static int
QuorumPeer. countParticipants(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> peers)
Count the number of nodes in the map that could be followers.void
QuorumPeer. setQuorumPeers(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers)
Constructors in org.apache.zookeeper.server.quorum with parameters of type QuorumPeer.QuorumServer Constructor Description RemotePeerBean(QuorumPeer.QuorumServer peer)
Constructor parameters in org.apache.zookeeper.server.quorum with type arguments of type QuorumPeer.QuorumServer Constructor Description QuorumCnxManager(long mySid, java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> view, QuorumAuthServer authServer, QuorumAuthLearner authLearner, int socketTimeout, boolean listenOnAllIPs, int quorumCnxnThreadsSize, boolean quorumSaslAuthEnabled)
QuorumCnxManager(long mySid, java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> view, QuorumAuthServer authServer, QuorumAuthLearner authLearner, int socketTimeout, boolean listenOnAllIPs, int quorumCnxnThreadsSize, boolean quorumSaslAuthEnabled, java.util.concurrent.ConcurrentHashMap<java.lang.Long,org.apache.zookeeper.server.quorum.QuorumCnxManager.SendWorker> senderWorkerMap)
QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File snapDir, java.io.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(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File snapDir, java.io.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(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File dataDir, java.io.File dataLogDir, int electionType, long myid, int tickTime, int initLimit, int syncLimit, boolean quorumListenOnAllIPs, ServerCnxnFactory cnxnFactory, QuorumVerifier quorumConfig)
QuorumPeer(java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> quorumPeers, java.io.File dataDir, java.io.File dataLogDir, int electionType, long myid, int tickTime, int initLimit, int syncLimit, ServerCnxnFactory cnxnFactory)
For backward compatibility purposes, we instantiate QuorumMaj by default.
-