| Package | Description |
|---|---|
| com.hazelcast.cp.internal.raft.impl.dto |
Contains structs that are used in Raft RPCs
|
| com.hazelcast.cp.internal.raft.impl.log |
Contains the log abstraction which is maintained by the Raft algorithm
|
| com.hazelcast.cp.internal.raft.impl.persistence |
| Modifier and Type | Method and Description |
|---|---|
LogEntry[] |
AppendRequest.entries() |
| Constructor and Description |
|---|
AppendRequest(RaftEndpoint leader,
int term,
int prevLogTerm,
long prevLogIndex,
long leaderCommitIndex,
LogEntry[] entries,
long queryRound) |
| Modifier and Type | Class and Description |
|---|---|
class |
SnapshotEntry
Represents a snapshot in the
RaftLog. |
| Modifier and Type | Method and Description |
|---|---|
LogEntry[] |
RaftLog.getEntriesBetween(long fromEntryIndex,
long toEntryIndex)
Returns log entries between
fromEntryIndex and toEntryIndex, both inclusive. |
LogEntry |
RaftLog.getLogEntry(long entryIndex)
Returns the log entry stored at
entryIndex. |
LogEntry |
RaftLog.lastLogOrSnapshotEntry()
Returns the last entry in the Raft log,
either from the last log entry or from the last snapshot
if no logs are available.
|
| Modifier and Type | Method and Description |
|---|---|
List<LogEntry> |
RaftLog.deleteEntriesFrom(long entryIndex)
Deletes all log entries with
index >= entryIndex. |
| Modifier and Type | Method and Description |
|---|---|
void |
RaftLog.appendEntries(LogEntry... newEntries)
Appends new entries to the Raft log.
|
static RaftLog |
RaftLog.restoreRaftLog(int capacity,
SnapshotEntry snapshot,
LogEntry[] entries) |
static RaftLog |
RaftLog.restoreRaftLog(int capacity,
SnapshotEntry snapshot,
LogEntry[] entries,
RaftStateStore store) |
| Modifier and Type | Method and Description |
|---|---|
LogEntry[] |
RestoredRaftState.entries() |
| Modifier and Type | Method and Description |
|---|---|
void |
RaftStateStore.persistEntry(LogEntry entry)
Persists the given log entry.
|
void |
NopRaftStateStore.persistEntry(LogEntry entry) |
| Constructor and Description |
|---|
RestoredRaftState(RaftEndpoint localEndpoint,
Collection<RaftEndpoint> initialMembers,
int term,
RaftEndpoint votedFor,
SnapshotEntry snapshot,
LogEntry[] entries) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.