Struct ClusterStore 

pub struct ClusterStore { /* private fields */ }

Persistent cluster state store.

Implementations

impl ClusterStore

pub fn open(path: &Path) -> Result<Self>

Open or create a store at the given path.

pub fn apply(&self, entry: &RaftEntry) -> Result<()>

Apply a Raft log entry to the store.

pub fn get_node(&self, id: u64) -> Result<Option<NodeEntry>>

Get a node by ID.

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

Get all registered nodes.

pub fn get_service(&self, name: &str) -> Result<Option<ServiceConfig>>

Get a service config by name.

pub fn set_service(&self, name: &str, config: &ServiceConfig) -> Result<()>

pub fn remove_service(&self, name: &str) -> Result<()>

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

Get all service configs.

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

Get assignments for a service.

pub fn snapshot(&self) -> Result<RaftSnapshot>

Take a full snapshot of the store.

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

Get all assignments across all services.

impl ClusterStore

pub fn restore_from_snapshot(&self, snap: &RaftSnapshot) -> Result<()>

Restore the store from a snapshot, replacing all data atomically.