Package | Description |
---|---|
org.apache.zookeeper.server.quorum | |
org.apache.zookeeper.server.quorum.flexible |
Modifier and Type | Method and Description |
---|---|
List<LearnerHandler> |
Leader.getForwardingFollowers()
Returns a copy of the current forwarding follower snapshot
|
List<LearnerHandler> |
Leader.getLearners()
Returns a copy of the current learner snapshot
|
List<LearnerHandler> |
Leader.getNonVotingFollowers() |
List<LearnerHandler> |
Leader.getObservingLearners()
Returns a copy of the current observer snapshot
|
Modifier and Type | Method and Description |
---|---|
void |
ObserverMaster.addLearnerHandler(LearnerHandler learnerHandler) |
void |
Leader.addLearnerHandler(LearnerHandler learner)
Adds peer to the leader.
|
void |
ObserverMaster.registerLearnerHandlerBean(LearnerHandler learnerHandler,
Socket socket) |
void |
Leader.registerLearnerHandlerBean(LearnerHandler learnerHandler,
Socket socket) |
void |
ObserverMaster.removeLearnerHandler(LearnerHandler learnerHandler) |
void |
Leader.removeLearnerHandler(LearnerHandler peer)
Remove the learner from the learner list
|
void |
ObserverMaster.revalidateSession(QuorumPacket qp,
LearnerHandler learnerHandler) |
void |
Leader.revalidateSession(QuorumPacket qp,
LearnerHandler learnerHandler) |
long |
ObserverMaster.startForwarding(LearnerHandler learnerHandler,
long lastSeenZxid) |
long |
Leader.startForwarding(LearnerHandler handler,
long lastSeenZxid)
lets the leader know that a follower is capable of following and is done
syncing
|
void |
ObserverMaster.unregisterLearnerHandlerBean(LearnerHandler learnerHandler) |
void |
Leader.unregisterLearnerHandlerBean(LearnerHandler learnerHandler) |
Constructor and Description |
---|
LearnerHandlerBean(LearnerHandler learnerHandler,
Socket socket) |
LearnerSyncRequest(LearnerHandler fh,
long sessionId,
int xid,
int type,
ByteBuffer bb,
List<Id> authInfo) |
Modifier and Type | Method and Description |
---|---|
default boolean |
QuorumVerifier.overrideQuorumDecision(List<LearnerHandler> forwardingFollowers) |
boolean |
QuorumOracleMaj.overrideQuorumDecision(List<LearnerHandler> forwardingFollowers) |
default boolean |
QuorumVerifier.updateNeedOracle(List<LearnerHandler> forwardingFollowers) |
boolean |
QuorumOracleMaj.updateNeedOracle(List<LearnerHandler> forwardingFollowers) |
Copyright © 2008–2022 The Apache Software Foundation. All rights reserved.