Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.quorum | |
org.apache.zookeeper.server.quorum.flexible |
Modifier and Type | Field and Description |
---|---|
QuorumVerifier |
Request.qv |
Modifier and Type | Method and Description |
---|---|
void |
ZKDatabase.initConfigInZKDatabase(QuorumVerifier qv) |
Modifier and Type | Field and Description |
---|---|
protected QuorumVerifier |
QuorumPeerConfig.lastSeenQuorumVerifier |
protected QuorumVerifier |
QuorumPeerConfig.quorumVerifier |
Modifier and Type | Method and Description |
---|---|
QuorumVerifier |
QuorumPeer.configFromString(String s) |
QuorumVerifier |
QuorumPeerConfig.getLastSeenQuorumVerifier() |
QuorumVerifier |
QuorumPeer.getLastSeenQuorumVerifier()
Return QuorumVerifier object for the last proposed configuration.
|
QuorumVerifier |
QuorumPeerConfig.getQuorumVerifier() |
QuorumVerifier |
SyncedLearnerTracker.QuorumVerifierAcksetPair.getQuorumVerifier() |
QuorumVerifier |
QuorumPeer.getQuorumVerifier()
Return QuorumVerifier object for the last committed configuration.
|
static QuorumVerifier |
QuorumPeerConfig.parseDynamicConfig(Properties dynamicConfigProp,
int eAlg,
boolean warnings,
boolean configBackwardCompatibilityMode,
String oraclePath)
Parse dynamic configuration file and return
quorumVerifier for new configuration.
|
QuorumVerifier |
QuorumPeer.setQuorumVerifier(QuorumVerifier qv,
boolean writeToDisk) |
Modifier and Type | Method and Description |
---|---|
void |
SyncedLearnerTracker.addQuorumVerifier(QuorumVerifier qv) |
boolean |
Leader.isQuorumSynced(QuorumVerifier qv)
Returns true if a quorum in qv is connected and synced with the leader
and false otherwise
|
boolean |
QuorumPeer.processReconfig(QuorumVerifier qv,
Long suggestedLeaderId,
Long zxid,
boolean restartLE) |
void |
QuorumPeer.restartLeaderElection(QuorumVerifier qvOLD,
QuorumVerifier qvNEW) |
void |
QuorumPeer.setLastSeenQuorumVerifier(QuorumVerifier qv,
boolean writeToDisk) |
QuorumVerifier |
QuorumPeer.setQuorumVerifier(QuorumVerifier qv,
boolean writeToDisk) |
static void |
QuorumPeerConfig.writeDynamicConfig(String dynamicConfigFilename,
QuorumVerifier qv,
boolean needKeepVersion)
Writes dynamic configuration file
|
Constructor and Description |
---|
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) |
QuorumVerifierAcksetPair(QuorumVerifier qv,
HashSet<Long> ackset) |
Modifier and Type | Class and Description |
---|---|
class |
QuorumHierarchical
This class implements a validator for hierarchical quorums.
|
class |
QuorumMaj
This class implements a validator for majority quorums.
|
class |
QuorumOracleMaj |
Copyright © 2008–2023 The Apache Software Foundation. All rights reserved.