Struct LeaderSelector 

pub struct LeaderSelector { /* private fields */ }

Simple leader selector that determines leadership based on cluster membership

Implementations

impl LeaderSelector

pub fn new() -> Self

Create a new leader selector with an empty cluster view

pub fn with_cluster(nodes: HashSet<NodeId>) -> Self

Create a new leader selector with initial cluster nodes

pub fn determine_leader(&self) -> Option<NodeId>

Determine the leader from the current cluster view

Returns the first node in the sorted cluster view, or None if empty

pub fn update_cluster_view(&mut self, nodes: HashSet<NodeId>) -> Option<NodeId>

Update the cluster view with new set of nodes

Returns the new leader if it changed, or None if no change

pub fn add_node(&mut self, node_id: NodeId) -> Option<NodeId>

Add a node to the cluster view

Returns the new leader if it changed

pub fn remove_node(&mut self, node_id: NodeId) -> Option<NodeId>

Remove a node from the cluster view

Returns the new leader if it changed

pub fn get_leader(&self) -> Option<NodeId>

Get the current leader

pub fn is_leader(&self, node_id: NodeId) -> bool

Check if a specific node is the current leader

pub fn get_cluster_view(&self) -> &[NodeId]

Get the current cluster view

pub fn get_leadership_info(&self) -> LeadershipInfo

Get current leadership information

pub fn has_nodes(&self) -> bool

Check if the cluster has any nodes

pub fn cluster_size(&self) -> usize

Get the number of nodes in the cluster

Trait Implementations

impl Clone for LeaderSelector

fn clone(&self) -> LeaderSelector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LeaderSelector

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

Formats the value using the given formatter.

impl Default for LeaderSelector

fn default() -> Self

Returns the “default value” for a type.