Struct ClusterState 

pub struct ClusterState {
    pub raft: Arc<OrcaRaft>,
    pub store: Arc<ClusterStore>,
}

Cluster state manager wrapping Raft consensus.

Fields

raft: Arc<OrcaRaft>

The Raft node.

store: Arc<ClusterStore>

Local state store (reads served directly).

Implementations

impl ClusterState

pub fn new(raft: Arc<OrcaRaft>, store: Arc<ClusterStore>) -> Self

Create a new cluster state manager.

pub fn get_nodes(&self) -> Result<HashMap<u64, NodeEntry>>

Get all registered nodes.

pub fn get_services(&self) -> Result<HashMap<String, ServiceConfig>>

Get all service configs.

pub fn get_all_assignments(&self) -> Result<Vec<Assignment>>

Get all workload assignments.

pub fn get_assignments(&self, service: &str) -> Result<Vec<Assignment>>

Get assignments for a specific service.

pub fn get_node_assignments(&self, node_id: u64) -> Result<Vec<Assignment>>

Get assignments for a specific node.

pub async fn propose_deploy(&self, services: &[ServiceConfig]) -> Result<()>

Deploy services — proposes SetService entries to Raft.

pub async fn register_node( &self, node_id: u64, address: String, labels: HashMap<String, String>, ) -> Result<()>

Register a node in the cluster.

pub async fn assign_workload( &self, service: &str, replica_idx: u32, node_id: u64, ) -> Result<()>

Assign a workload replica to a node.

pub async fn unassign_workload( &self, service: &str, replica_idx: u32, node_id: u64, ) -> Result<()>

Unassign a workload replica from a node.