Struct ClusterState 

pub struct ClusterState { /* private fields */ }

Cluster state management

Implementations

impl ClusterState

pub fn new() -> Self

Create a new cluster state

pub fn update_topology(&mut self, nodes: &[NodeInfo]) -> CoreResult<()>

Update the cluster topology with new node information

pub fn needs_leader_election(&self) -> bool

Check if leader election is needed

pub fn set_leader(&mut self, nodeid: String)

Set the cluster leader

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

Get the current cluster leader

pub fn get_topology(&self) -> &ClusterTopology

Get the cluster topology

pub fn last_updated(&self) -> Instant

Get the last update timestamp

pub fn is_stale(&self, max_age: Duration) -> bool

Check if the cluster state is stale

pub fn reset(&mut self)

Reset cluster state

Trait Implementations

impl Debug for ClusterState

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

Formats the value using the given formatter.

impl Default for ClusterState

fn default() -> Self

Returns the “default value” for a type.