Struct ClusterState 

pub struct ClusterState {
    pub config: Arc<RwLock<ClusterConfig>>,
    pub local_node: NodeId,
    pub consensus_state: Arc<RwLock<ConsensusState>>,
    pub partition_table: Arc<RwLock<PartitionTable>>,
}

Cluster state

Fields

config: Arc<RwLock<ClusterConfig>>

local_node: NodeId

consensus_state: Arc<RwLock<ConsensusState>>

partition_table: Arc<RwLock<PartitionTable>>

Implementations

impl ClusterState

pub fn new(local_node: NodeId) -> Self

Create a new cluster state

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

Get the current leader node

pub async fn is_leader(&self) -> bool

Check if this node is the leader

pub async fn get_partition_for_key(&self, key: &[u8]) -> PartitionId

Get partition assignment for a key

pub async fn get_nodes_for_partition( &self, partition: &PartitionId, ) -> Vec<NodeId>

Get nodes responsible for a partition

pub async fn get_nodes_for_key(&self, key: &[u8]) -> Vec<NodeId>

Get nodes responsible for a key

pub async fn get_partitions_for_node( &self, node_id: &NodeId, ) -> Vec<PartitionId>

Get partitions for a node

Trait Implementations

impl Debug for ClusterState

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

Formats the value using the given formatter.