Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.quorum |
Modifier and Type | Field and Description |
---|---|
protected Queue<Leader.Proposal> |
ZKDatabase.committedLog |
Modifier and Type | Method and Description |
---|---|
Leader.Proposal |
TxnLogProposalIterator.next()
Proposal returned by this iterator has request part set to null, since
it is not used for follower sync-up.
|
Modifier and Type | Method and Description |
---|---|
Collection<Leader.Proposal> |
ZKDatabase.getCommittedLog() |
Iterator<Leader.Proposal> |
ZKDatabase.getProposalsFromTxnLog(long startZxid,
long sizeLimit)
Get proposals from txnlog.
|
Modifier and Type | Field and Description |
---|---|
protected Leader.Proposal |
Leader.newLeaderProposal |
Modifier and Type | Method and Description |
---|---|
Leader.Proposal |
Leader.propose(Request request)
create a proposal and send it out to all the members
|
Modifier and Type | Method and Description |
---|---|
void |
Leader.inform(Leader.Proposal proposal)
Create an inform packet and send it to all observers.
|
void |
Leader.informAndActivate(Leader.Proposal proposal,
long designatedLeader)
Create an inform and activate packet and send it to all observers.
|
boolean |
Leader.tryToCommit(Leader.Proposal p,
long zxid,
SocketAddress followerAddr) |
Modifier and Type | Method and Description |
---|---|
protected long |
LearnerHandler.queueCommittedProposals(Iterator<Leader.Proposal> itr,
long peerLastZxid,
Long maxZxid,
Long lastCommittedZxid)
Queue committed proposals into packet queue.
|
Copyright © 2008–2021 The Apache Software Foundation. All rights reserved.