Struct ClusterState 

pub struct ClusterState {
    pub nodes: HashMap<NodeId, ClusterNode>,
    pub local_id: NodeId,
    pub config_epoch: u64,
    pub slot_map: SlotMap,
    pub state: ClusterHealth,
}

The complete state of the cluster as seen by a node.

Fields

nodes: HashMap<NodeId, ClusterNode>

All known nodes in the cluster, indexed by ID.

local_id: NodeId

This node’s ID.

config_epoch: u64

Current configuration epoch (increases on topology changes).

slot_map: SlotMap

Slot-to-node mapping.

state: ClusterHealth

Cluster state: ok, fail, or unknown.

Implementations

impl ClusterState

pub fn single_node(local_node: ClusterNode) -> Self

Creates a new cluster state for a single-node cluster.

pub fn new(local_id: NodeId) -> Self

Creates a new empty cluster state (for joining an existing cluster).

pub fn local_node(&self) -> Option<&ClusterNode>

Returns the local node.

pub fn local_node_mut(&mut self) -> Option<&mut ClusterNode>

Returns a mutable reference to the local node.

pub fn add_node(&mut self, node: ClusterNode)

Adds a node to the cluster.

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

Removes a node from the cluster.

pub fn slot_owner(&self, slot: u16) -> Option<&ClusterNode>

Returns the node that owns the given slot.

pub fn owns_slot(&self, slot: u16) -> bool

Returns true if the local node owns the given slot.

pub fn primaries(&self) -> impl Iterator<Item = &ClusterNode>

Returns all primary nodes.

pub fn replicas(&self) -> impl Iterator<Item = &ClusterNode>

Returns all replica nodes.

pub fn replicas_of( &self, primary_id: NodeId, ) -> impl Iterator<Item = &ClusterNode>

Returns replicas of a specific primary.

pub fn update_health(&mut self)

Computes and updates the cluster health state.

pub fn cluster_info(&self) -> String

Generates the response for CLUSTER INFO command.

pub fn cluster_nodes(&self) -> String

Generates the response for CLUSTER NODES command.

pub fn moved_redirect( &self, slot: u16, ) -> Result<(u16, SocketAddr), ClusterError>

Generates MOVED redirect information for a slot.

Trait Implementations

impl Debug for ClusterState

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

Formats the value using the given formatter.