Package | Description |
---|---|
org.apache.zookeeper.server.quorum |
Modifier and Type | Field and 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 cluster
|
protected java.util.HashMap<java.lang.Long,QuorumPeer.QuorumServer> |
QuorumPeerConfig.servers |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and 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) |
Constructor and Description |
---|
RemotePeerBean(QuorumPeer.QuorumServer peer) |
Constructor and Description |
---|
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.
|
Copyright © 2019 The Apache Software Foundation