, including all inherited members.
advanceCommitIndex() | LogCabin::Server::RaftConsensus | [private] |
append(const std::vector< const Storage::Log::Entry * > &entries) | LogCabin::Server::RaftConsensus | [private] |
appendEntries(std::unique_lock< Mutex > &lockGuard, Peer &peer) | LogCabin::Server::RaftConsensus | [private] |
becomeLeader() | LogCabin::Server::RaftConsensus | [private] |
beginSnapshot(uint64_t lastIncludedIndex) | LogCabin::Server::RaftConsensus | |
bootstrapConfiguration() | LogCabin::Server::RaftConsensus | |
CANDIDATE enum value | LogCabin::Server::RaftConsensus | [private] |
ClientResult enum name | LogCabin::Server::RaftConsensus | |
Clock typedef | LogCabin::Server::RaftConsensus | |
ClusterClock typedef | LogCabin::Server::RaftConsensus | |
clusterClock | LogCabin::Server::RaftConsensus | [private] |
commitIndex | LogCabin::Server::RaftConsensus | [private] |
Configuration typedef | LogCabin::Server::RaftConsensus | |
configuration | LogCabin::Server::RaftConsensus | [private] |
ConfigurationManager typedef | LogCabin::Server::RaftConsensus | |
configurationManager | LogCabin::Server::RaftConsensus | [private] |
currentEpoch | LogCabin::Server::RaftConsensus | [mutable, private] |
currentTerm | LogCabin::Server::RaftConsensus | [private] |
discardUnneededEntries() | LogCabin::Server::RaftConsensus | [private] |
ELECTION_TIMEOUT | LogCabin::Server::RaftConsensus | [private] |
exit() | LogCabin::Server::RaftConsensus | |
exiting | LogCabin::Server::RaftConsensus | [private] |
FAIL enum value | LogCabin::Server::RaftConsensus | |
FOLLOWER enum value | LogCabin::Server::RaftConsensus | [private] |
getConfiguration(Protocol::Raft::SimpleConfiguration &configuration, uint64_t &id) const | LogCabin::Server::RaftConsensus | |
getLastCommitIndex() const | LogCabin::Server::RaftConsensus | |
getLastLogTerm() const | LogCabin::Server::RaftConsensus | [private] |
getLeaderHint() const | LogCabin::Server::RaftConsensus | |
getNextEntry(uint64_t lastIndex) const | LogCabin::Server::RaftConsensus | |
getSnapshotStats() const | LogCabin::Server::RaftConsensus | |
globals | LogCabin::Server::RaftConsensus | [private] |
handleAppendEntries(const Protocol::Raft::AppendEntries::Request &request, Protocol::Raft::AppendEntries::Response &response) | LogCabin::Server::RaftConsensus | |
handleInstallSnapshot(const Protocol::Raft::InstallSnapshot::Request &request, Protocol::Raft::InstallSnapshot::Response &response) | LogCabin::Server::RaftConsensus | |
handleRequestVote(const Protocol::Raft::RequestVote::Request &request, Protocol::Raft::RequestVote::Response &response) | LogCabin::Server::RaftConsensus | |
HEARTBEAT_PERIOD | LogCabin::Server::RaftConsensus | [private] |
init() | LogCabin::Server::RaftConsensus | |
installSnapshot(std::unique_lock< Mutex > &lockGuard, Peer &peer) | LogCabin::Server::RaftConsensus | [private] |
interruptAll() | LogCabin::Server::RaftConsensus | [private] |
invariants | LogCabin::Server::RaftConsensus | [private] |
Invariants typedef | LogCabin::Server::RaftConsensus | |
lastSnapshotBytes | LogCabin::Server::RaftConsensus | [private] |
lastSnapshotClusterTime | LogCabin::Server::RaftConsensus | [private] |
lastSnapshotIndex | LogCabin::Server::RaftConsensus | [private] |
lastSnapshotTerm | LogCabin::Server::RaftConsensus | [private] |
LEADER enum value | LogCabin::Server::RaftConsensus | [private] |
leaderDiskThread | LogCabin::Server::RaftConsensus | [private] |
leaderDiskThreadMain() | LogCabin::Server::RaftConsensus | [private] |
leaderDiskThreadWorking | LogCabin::Server::RaftConsensus | [private] |
leaderId | LogCabin::Server::RaftConsensus | [private] |
LocalServer typedef | LogCabin::Server::RaftConsensus | |
log | LogCabin::Server::RaftConsensus | [private] |
logSyncQueued | LogCabin::Server::RaftConsensus | [private] |
MAX_LOG_ENTRIES_PER_REQUEST | LogCabin::Server::RaftConsensus | [private] |
Mutex typedef | LogCabin::Server::RaftConsensus | |
mutex | LogCabin::Server::RaftConsensus | [mutable, private] |
NOT_LEADER enum value | LogCabin::Server::RaftConsensus | |
numEntriesTruncated | LogCabin::Server::RaftConsensus | [private] |
numPeerThreads | LogCabin::Server::RaftConsensus | [private] |
operator<<(std::ostream &os, const RaftConsensus &raft) | LogCabin::Server::RaftConsensus | [friend] |
operator<<(std::ostream &os, ClientResult clientResult) | LogCabin::Server::RaftConsensus | [friend] |
operator<<(std::ostream &os, State state) | LogCabin::Server::RaftConsensus | [friend] |
packEntries(uint64_t nextIndex, Protocol::Raft::AppendEntries::Request &request) const | LogCabin::Server::RaftConsensus | [private] |
Peer typedef | LogCabin::Server::RaftConsensus | |
peerThreadMain(std::shared_ptr< Peer > peer) | LogCabin::Server::RaftConsensus | [private] |
printElectionState() const | LogCabin::Server::RaftConsensus | [private] |
RaftConsensus(Globals &globals) | LogCabin::Server::RaftConsensus | [explicit] |
RaftConsensusInternal::Invariants class | LogCabin::Server::RaftConsensus | [friend] |
RaftConsensusInternal::LocalServer class | LogCabin::Server::RaftConsensus | [friend] |
RaftConsensusInternal::Peer class | LogCabin::Server::RaftConsensus | [friend] |
readSnapshot() | LogCabin::Server::RaftConsensus | [private] |
replicate(const Core::Buffer &operation) | LogCabin::Server::RaftConsensus | |
replicateEntry(Storage::Log::Entry &entry, std::unique_lock< Mutex > &lockGuard) | LogCabin::Server::RaftConsensus | [private] |
requestVote(std::unique_lock< Mutex > &lockGuard, Peer &peer) | LogCabin::Server::RaftConsensus | [private] |
RETRY enum value | LogCabin::Server::RaftConsensus | |
RPC_FAILURE_BACKOFF | LogCabin::Server::RaftConsensus | [private] |
Server typedef | LogCabin::Server::RaftConsensus | |
serverAddresses | LogCabin::Server::RaftConsensus | |
serverId | LogCabin::Server::RaftConsensus | |
sessionManager | LogCabin::Server::RaftConsensus | [private] |
setConfiguration(const Protocol::Client::SetConfiguration::Request &request, Protocol::Client::SetConfiguration::Response &response) | LogCabin::Server::RaftConsensus | |
setElectionTimer() | LogCabin::Server::RaftConsensus | [private] |
setSupportedStateMachineVersions(uint16_t minSupported, uint16_t maxSupported) | LogCabin::Server::RaftConsensus | |
snapshotDone(uint64_t lastIncludedIndex, std::unique_ptr< Storage::SnapshotFile::Writer > writer) | LogCabin::Server::RaftConsensus | |
snapshotReader | LogCabin::Server::RaftConsensus | [mutable, private] |
snapshotWriter | LogCabin::Server::RaftConsensus | [private] |
SOFT_RPC_SIZE_LIMIT | LogCabin::Server::RaftConsensus | [private] |
startElectionAt | LogCabin::Server::RaftConsensus | [private] |
startNewElection() | LogCabin::Server::RaftConsensus | [private] |
state | LogCabin::Server::RaftConsensus | [private] |
State enum name | LogCabin::Server::RaftConsensus | [private] |
STATE_MACHINE_UPDATER_BACKOFF | LogCabin::Server::RaftConsensus | [private] |
stateChanged | LogCabin::Server::RaftConsensus | [mutable, private] |
stateMachineUpdaterThread | LogCabin::Server::RaftConsensus | [private] |
stateMachineUpdaterThreadMain() | LogCabin::Server::RaftConsensus | [private] |
stepDown(uint64_t newTerm) | LogCabin::Server::RaftConsensus | [private] |
stepDownThread | LogCabin::Server::RaftConsensus | [private] |
stepDownThreadMain() | LogCabin::Server::RaftConsensus | [private] |
storageLayout | LogCabin::Server::RaftConsensus | [private] |
SUCCESS enum value | LogCabin::Server::RaftConsensus | |
TimePoint typedef | LogCabin::Server::RaftConsensus | |
timerThread | LogCabin::Server::RaftConsensus | [private] |
timerThreadMain() | LogCabin::Server::RaftConsensus | [private] |
updateLogMetadata() | LogCabin::Server::RaftConsensus | [private] |
updateServerStats(Protocol::ServerStats &serverStats) const | LogCabin::Server::RaftConsensus | |
upToDateLeader(std::unique_lock< Mutex > &lockGuard) const | LogCabin::Server::RaftConsensus | [private] |
votedFor | LogCabin::Server::RaftConsensus | [private] |
withholdVotesUntil | LogCabin::Server::RaftConsensus | [private] |
~RaftConsensus() | LogCabin::Server::RaftConsensus | |