public class ObserverZooKeeperServer extends LearnerZooKeeperServer
ZooKeeperServer.BasicDataTreeBuilder, ZooKeeperServer.DataTreeBuilder, ZooKeeperServer.MissingSessionException
self
DEFAULT_TICK_TIME, firstProcessor, hzxid, jmxDataTreeBean, jmxServerBean, maxSessionTimeout, minSessionTimeout, ok, running, sessionTracker, tickTime
Modifier and Type | Method and Description |
---|---|
void |
commitRequest(Request request)
Unlike a Follower, which sees a full request only during the PROPOSAL
phase, Observers get all the data required with the INFORM packet.
|
Learner |
getLearner()
Abstract method to return the learner associated with this server.
|
Observer |
getObserver() |
java.lang.String |
getState() |
protected void |
setupRequestProcessors()
Set up the request processors for an Observer:
firstProcesor->commitProcessor->finalProcessor
|
void |
sync() |
createSessionTracker, getServerId, getTouchSnapshot, registerJMX, registerJMX, revalidateSession, startSessionTracker, unregisterJMX, unregisterJMX
dumpConf
checkPasswd, closeSession, closeSession, decInProcess, dumpEphemerals, expire, finishSessionInit, getClientPort, getGlobalOutstandingLimit, getInProcess, getLastProcessedZxid, getMaxSessionTimeout, getMinSessionTimeout, getNumAliveConnections, getOutstandingRequests, getServerCnxnFactory, getSnapCount, getTickTime, getTxnLogFactory, getZKDatabase, getZxid, incInProcess, isRunning, killSession, loadData, processConnectRequest, processPacket, processTxn, reopenSession, serverStats, setMaxSessionTimeout, setMinSessionTimeout, setOwner, setServerCnxnFactory, setTickTime, setTxnLogFactory, setZKDatabase, setZxid, shouldThrottle, shutdown, startdata, startup, submitRequest, takeSnapshot, truncateLog
public Observer getObserver()
public Learner getLearner()
LearnerZooKeeperServer
getLearner
in class LearnerZooKeeperServer
public void commitRequest(Request request)
request
- protected void setupRequestProcessors()
setupRequestProcessors
in class ZooKeeperServer
public void sync()
public java.lang.String getState()
getState
in interface ServerStats.Provider
getState
in class ZooKeeperServer
Copyright © 2024 The Apache Software Foundation