Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.quorum |
Modifier and Type | Method and Description |
---|---|
ZKDatabase |
ZooKeeperServer.getZKDatabase()
get the zookeeper database for this server
|
Modifier and Type | Method and Description |
---|---|
void |
ZooKeeperServer.setZKDatabase(ZKDatabase zkDb)
set the zkdatabase for this zookeeper server
|
Constructor and Description |
---|
ContainerManager(ZKDatabase zkDb,
RequestProcessor requestProcessor,
int checkIntervalMs,
int maxPerMinute) |
ZooKeeperServer(FileTxnSnapLog txnLogFactory,
int tickTime,
int minSessionTimeout,
int maxSessionTimeout,
ZKDatabase zkDb)
Creates a ZooKeeperServer instance.
|
Modifier and Type | Method and Description |
---|---|
protected ZKDatabase |
QuorumPeer.getZkDb() |
Modifier and Type | Method and Description |
---|---|
void |
QuorumPeer.setZKDatabase(ZKDatabase database)
set zk database for this node
|
boolean |
LearnerHandler.syncFollower(long peerLastZxid,
ZKDatabase db,
Leader leader)
Determine if we need to sync with follower using DIFF/TRUNC/SNAP
and setup follower to receive packets from commit processor
|
Constructor and Description |
---|
LearnerZooKeeperServer(FileTxnSnapLog logFactory,
int tickTime,
int minSessionTimeout,
int maxSessionTimeout,
ZKDatabase zkDb,
QuorumPeer self) |
QuorumZooKeeperServer(FileTxnSnapLog logFactory,
int tickTime,
int minSessionTimeout,
int maxSessionTimeout,
ZKDatabase zkDb,
QuorumPeer self) |
Copyright © 2008–2019 The Apache Software Foundation. All rights reserved.