Struct LeaderState 

pub struct LeaderState {
    pub next_index: HashMap<NodeId, LogIndex>,
    pub match_index: HashMap<NodeId, LogIndex>,
}

Volatile state on leaders

Reinitialized after election

Fields

next_index: HashMap<NodeId, LogIndex>

For each server, index of the next log entry to send to that server (initialized to leader last log index + 1)

match_index: HashMap<NodeId, LogIndex>

For each server, index of highest log entry known to be replicated (initialized to 0, increases monotonically)

Implementations

impl LeaderState

pub fn new(cluster_members: &[NodeId], last_log_index: LogIndex) -> Self

Create new leader state for the given cluster members

pub fn decrement_next_index(&mut self, node_id: &NodeId)

Update next_index for a follower (decrement on failure)

pub fn update_replication(&mut self, node_id: &NodeId, match_index: LogIndex)

Update both next_index and match_index for successful replication

pub fn calculate_commit_index(&self) -> LogIndex

Get the median match_index for determining commit_index

pub fn get_next_index(&self, node_id: &NodeId) -> Option<LogIndex>

Get next_index for a specific follower

pub fn get_match_index(&self, node_id: &NodeId) -> Option<LogIndex>

Get match_index for a specific follower

Trait Implementations

impl Clone for LeaderState

fn clone(&self) -> LeaderState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LeaderState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.