com.hazelcast.cp.internal.raft.impl.state

Class LeaderState

java.lang.Object

com.hazelcast.cp.internal.raft.impl.state.LeaderState

public class LeaderState
extends Object

Mutable state maintained by the leader of the Raft group. Leader keeps a FollowerState object for each follower.

See Also:

FollowerState

Method Summary

Modifier and Type	Method and Description
void	add(Endpoint follower, long lastLogIndex) Add a new follower with the leader's lastLogIndex.
FollowerState	getFollowerState(Endpoint follower)
Map<Endpoint,FollowerState>	getFollowerStates()
long	majorityAppendRequestAckTimestamp(int majority) Returns the earliest append response ack timestamp of the majority nodes
long[]	matchIndices() Returns an array of match indices for all followers.
void	remove(Endpoint follower) Removes a follower from leader maintained state.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

add

public void add(Endpoint follower,
                long lastLogIndex)

Add a new follower with the leader's lastLogIndex. Follower's nextIndex will be set to lastLogIndex + 1 and matchIndex to 0.

remove

public void remove(Endpoint follower)

Removes a follower from leader maintained state.

matchIndices

public long[] matchIndices()

Returns an array of match indices for all followers. Additionally an empty slot is added at the end of indices array for leader itself.

getFollowerState

public FollowerState getFollowerState(Endpoint follower)

getFollowerStates

public Map<Endpoint,FollowerState> getFollowerStates()

majorityAppendRequestAckTimestamp

public long majorityAppendRequestAckTimestamp(int majority)

Returns the earliest append response ack timestamp of the majority nodes