Package | Description |
---|---|
com.hazelcast.cp.internal.persistence | |
com.hazelcast.cp.internal.raft.impl |
Contains implementation classes of the Raft algorithm
|
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 | |
com.hazelcast.cp.internal.raft.impl.state |
Contains classes that keep state of Raft nodes
|
Modifier and Type | Method and Description |
---|---|
RaftStateStore |
CPPersistenceService.createRaftStateStore(RaftGroupId groupId,
LogFileStructure logFileStructure)
Creates a
RaftStateStore that is going to be used by the local Raft node
of the given CP group. |
RaftStateStore |
NopCPPersistenceService.createRaftStateStore(RaftGroupId groupId,
LogFileStructure logFileStructure) |
Modifier and Type | Method and Description |
---|---|
static RaftNodeImpl |
RaftNodeImpl.newRaftNode(CPGroupId groupId,
RaftEndpoint localMember,
Collection<RaftEndpoint> members,
RaftAlgorithmConfig config,
RaftIntegration integration,
RaftStateStore raftStateStore)
Creates a new Raft node with an empty initial state
and a
RaftStateStore to persist Raft state changes |
static RaftNodeImpl |
RaftNodeImpl.restoreRaftNode(CPGroupId groupId,
RestoredRaftState restoredState,
RaftAlgorithmConfig config,
RaftIntegration integration,
RaftStateStore raftStateStore)
Creates a new Raft node with restored Raft state
and a
RaftStateStore to persist Raft state changes |
Modifier and Type | Method and Description |
---|---|
static RaftLog |
RaftLog.newRaftLog(int capacity,
RaftStateStore store) |
static RaftLog |
RaftLog.restoreRaftLog(int capacity,
SnapshotEntry snapshot,
LogEntry[] entries,
RaftStateStore store) |
Modifier and Type | Class and Description |
---|---|
class |
NopRaftStateStore
Used when a Raft node works transiently (its state is not persisted).
|
Modifier and Type | Field and Description |
---|---|
static RaftStateStore |
NopRaftStateStore.INSTANCE
Non-persisting
RaftStateStore instance |
Modifier and Type | Method and Description |
---|---|
RaftStateStore |
RaftState.stateStore()
Returns the state store that persists changes on this Raft state
|
Modifier and Type | Method and Description |
---|---|
static RaftState |
RaftState.newRaftState(CPGroupId groupId,
RaftEndpoint localEndpoint,
Collection<RaftEndpoint> endpoints,
int logCapacity,
RaftStateStore stateStore) |
static RaftState |
RaftState.restoreRaftState(CPGroupId groupId,
RestoredRaftState restoredState,
int logCapacity,
RaftStateStore stateStore) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.