| Package | Description |
|---|---|
| com.hazelcast.cp.internal.raft.impl |
Contains implementation classes of the Raft algorithm
|
| 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 |
|---|---|
boolean |
RaftNodeImpl.installSnapshot(SnapshotEntry snapshot)
Restores the snapshot sent by the leader if it's not applied before.
|
| Modifier and Type | Method and Description |
|---|---|
SnapshotEntry |
InstallSnapshot.snapshot() |
| Constructor and Description |
|---|
InstallSnapshot(RaftEndpoint leader,
int term,
SnapshotEntry snapshot,
long queryRound) |
| Modifier and Type | Method and Description |
|---|---|
SnapshotEntry |
RaftLog.snapshot()
Returns snapshot entry.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
SnapshotEntry.isNonInitial(SnapshotEntry entry) |
static RaftLog |
RaftLog.restoreRaftLog(int capacity,
SnapshotEntry snapshot,
LogEntry[] entries) |
static RaftLog |
RaftLog.restoreRaftLog(int capacity,
SnapshotEntry snapshot,
LogEntry[] entries,
RaftStateStore store) |
int |
RaftLog.setSnapshot(SnapshotEntry snapshot)
Installs the snapshot entry and truncates log entries those are included
in the snapshot (entries whose indexes are smaller than or equal to
the snapshot's index).
|
int |
RaftLog.setSnapshot(SnapshotEntry snapshot,
long truncateUpToIndex) |
| Modifier and Type | Method and Description |
|---|---|
SnapshotEntry |
RestoredRaftState.snapshot() |
| Modifier and Type | Method and Description |
|---|---|
void |
RaftStateStore.persistSnapshot(SnapshotEntry entry)
Persists the given snapshot entry.
|
void |
NopRaftStateStore.persistSnapshot(SnapshotEntry 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.