Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
ZooKeeperServer is designed to work in standalone mode and also
be extensible so that it can be used to implement the quorum based
version of ZooKeeper.
|
org.apache.zookeeper.server.persistence | |
org.apache.zookeeper.server.quorum | |
org.apache.zookeeper.server.upgrade | |
org.apache.zookeeper.server.util |
Modifier and Type | Field and Description |
---|---|
TxnHeader |
Request.hdr |
Modifier and Type | Method and Description |
---|---|
DataTree.ProcessTxnResult |
DataTree.processTxn(TxnHeader header,
org.apache.jute.Record txn) |
DataTree.ProcessTxnResult |
ZooKeeperServer.processTxn(TxnHeader hdr,
org.apache.jute.Record txn) |
DataTree.ProcessTxnResult |
ZKDatabase.processTxn(TxnHeader hdr,
org.apache.jute.Record txn)
the process txn on the data
|
Modifier and Type | Method and Description |
---|---|
TxnHeader |
FileTxnLog.FileTxnIterator.getHeader()
reutrn the current header
|
TxnHeader |
TxnLog.TxnIterator.getHeader()
return the transaction header.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FileTxnLog.append(TxnHeader hdr,
org.apache.jute.Record txn)
append an entry to the transaction log
|
boolean |
TxnLog.append(TxnHeader hdr,
org.apache.jute.Record r)
Append a request to the transaction log
|
static byte[] |
Util.marshallTxnEntry(TxnHeader hdr,
org.apache.jute.Record txn)
Serializes transaction header and transaction data into a byte buffer.
|
void |
FileTxnSnapLog.PlayBackListener.onTxnLoaded(TxnHeader hdr,
org.apache.jute.Record rec) |
void |
FileTxnSnapLog.processTransaction(TxnHeader hdr,
DataTree dt,
Map<Long,Integer> sessions,
org.apache.jute.Record txn)
process the transaction on the datatree
|
Modifier and Type | Method and Description |
---|---|
void |
FollowerZooKeeperServer.logRequest(TxnHeader hdr,
org.apache.jute.Record txn) |
Modifier and Type | Method and Description |
---|---|
DataTreeV1.ProcessTxnResult |
DataTreeV1.processTxn(TxnHeader header,
org.apache.jute.Record txn) |
Modifier and Type | Method and Description |
---|---|
static org.apache.jute.Record |
SerializeUtils.deserializeTxn(byte[] txnBytes,
TxnHeader hdr) |
Copyright © 2017 The Apache Software Foundation