Package | Description |
---|---|
com.hazelcast.cp.internal |
Contains implementation of CP Subsystem
|
com.hazelcast.cp.internal.raft.impl |
Contains implementation classes of the Raft algorithm
|
com.hazelcast.cp.internal.raft.impl.handler |
Contains request/response handler tasks.
|
com.hazelcast.cp.internal.raft.impl.task |
Contains tasks running on leader or leader-candidates.
|
Modifier and Type | Method and Description |
---|---|
RaftNodeImpl |
RaftService.restoreRaftNode(RaftGroupId groupId,
RestoredRaftState restoredState,
LogFileStructure logFileStructure) |
Modifier and Type | Method and Description |
---|---|
static RaftNodeImpl |
RaftNodeImpl.newRaftNode(CPGroupId groupId,
RaftEndpoint localMember,
Collection<RaftEndpoint> members,
RaftAlgorithmConfig config,
RaftIntegration integration)
Creates a new Raft node with an empty initial state.
|
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)
Creates a new Raft node with restored Raft state
|
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 |
Constructor and Description |
---|
AppendFailureResponseHandlerTask(RaftNodeImpl raftNode,
AppendFailureResponse response) |
AppendRequestHandlerTask(RaftNodeImpl raftNode,
AppendRequest req) |
AppendSuccessResponseHandlerTask(RaftNodeImpl raftNode,
AppendSuccessResponse response) |
InstallSnapshotHandlerTask(RaftNodeImpl raftNode,
InstallSnapshot req) |
PreVoteRequestHandlerTask(RaftNodeImpl raftNode,
PreVoteRequest req) |
PreVoteResponseHandlerTask(RaftNodeImpl raftNode,
PreVoteResponse response) |
TriggerLeaderElectionHandlerTask(RaftNodeImpl raftNode,
TriggerLeaderElection req) |
VoteRequestHandlerTask(RaftNodeImpl raftNode,
VoteRequest req) |
VoteResponseHandlerTask(RaftNodeImpl raftNode,
VoteResponse response) |
Modifier and Type | Field and Description |
---|---|
protected RaftNodeImpl |
RaftNodeStatusAwareTask.raftNode |
Constructor and Description |
---|
InitLeadershipTransferTask(RaftNodeImpl raftNode,
RaftEndpoint targetEndpoint,
InternalCompletableFuture resultFuture) |
LeaderElectionTask(RaftNodeImpl raftNode,
boolean disruptive) |
MembershipChangeTask(RaftNodeImpl raftNode,
InternalCompletableFuture resultFuture,
RaftEndpoint member,
MembershipChangeMode membershipChangeMode) |
MembershipChangeTask(RaftNodeImpl raftNode,
InternalCompletableFuture resultFuture,
RaftEndpoint member,
MembershipChangeMode membershipChangeMode,
Long groupMembersCommitIndex) |
PreVoteTask(RaftNodeImpl raftNode,
int term) |
QueryTask(RaftNodeImpl raftNode,
Object operation,
QueryPolicy policy,
InternalCompletableFuture resultFuture) |
RaftNodeStatusAwareTask(RaftNodeImpl raftNode) |
ReplicateTask(RaftNodeImpl raftNode,
Object operation,
InternalCompletableFuture resultFuture) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.