CompletableFuture<Ordered<RaftGroupMembers>> |
RaftNode.changeMembership(RaftEndpoint endpoint,
MembershipChangeMode mode,
long expectedGroupMembersCommitIndex) |
Replicates and commits the given membership change to the Raft group, if the
given group members commit index is equal to the current group members commit
index in the local Raft state.
|
CompletableFuture<Ordered<RaftNodeReport>> |
RaftNode.getReport() |
Returns a report object that contains information about this Raft node's
local state related to the execution of the Raft consensus algorithm.
|
<T> CompletableFuture<Ordered<T>> |
RaftNode.query(Object operation,
QueryPolicy queryPolicy,
long minCommitIndex) |
Executes the given query operation based on the given query policy.
|
<T> CompletableFuture<Ordered<T>> |
RaftNode.replicate(Object operation) |
Replicates, commits, and executes the given operation via this Raft node.
|
CompletableFuture<Ordered<Object>> |
RaftNode.start() |
Triggers this Raft node to start executing the Raft consensus algorithm.
|
CompletableFuture<Ordered<RaftNodeReport>> |
RaftNode.takeSnapshot() |
Takes a new snapshot at the local RaftNode at the current commit index.
|
CompletableFuture<Ordered<Object>> |
RaftNode.terminate() |
Forcefully sets the status of this Raft node to
RaftNodeStatus.TERMINATED and makes the Raft node stops executing the
Raft consensus algorithm. |
CompletableFuture<Ordered<Object>> |
RaftNode.transferLeadership(RaftEndpoint endpoint) |
Transfers the leadership role to the given endpoint, if this Raft node is the
current Raft group leader with the RaftNodeStatus.ACTIVE status and
the given endpoint is in the committed member list of the Raft group. |