Struct ClusterCatalog 

pub struct ClusterCatalog { /* private fields */ }

Persistent cluster catalog backed by redb.

Implementations

impl ClusterCatalog

pub fn save_cluster_settings(&self, settings: &ClusterSettings) -> Result<()>

Persist the cluster settings blob. Called once at bootstrap.

pub fn load_cluster_settings(&self) -> Result<Option<ClusterSettings>>

Load the cluster settings. Returns None if not yet bootstrapped.

impl ClusterCatalog

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

Open or create the cluster catalog at the given path.

Delegates to [super::migration::migrate_if_needed] after the redb tables are in place. Fresh catalogs get stamped with the current format version; catalogs stamped with a higher version than this binary supports are refused with a clear error (preventing silent corruption on an accidental downgrade). Future schema changes land as explicit migration arms in migration.rs.

pub fn save_cluster_id(&self, cluster_id: u64) -> Result<()>

Store the cluster ID (generated at bootstrap, immutable).

pub fn load_cluster_id(&self) -> Result<Option<u64>>

Load the cluster ID. Returns None if not yet bootstrapped.

pub fn is_bootstrapped(&self) -> Result<bool>

Check if this catalog has been bootstrapped (has a cluster_id).

pub fn save_cluster_epoch(&self, epoch: u64) -> Result<()>

Persist the cluster epoch (the leader-bumped monotonic fence token stamped on every Raft RPC). Overwrites any prior value.

pub fn load_cluster_epoch(&self) -> Result<Option<u64>>

Load the persisted cluster epoch. Returns None on a catalog that has never written one (callers treat that as 0).

pub fn save_ca_cert(&self, ca_cert_der: &[u8]) -> Result<()>

Store the cluster CA certificate (DER-encoded).

pub fn load_ca_cert(&self) -> Result<Option<Vec<u8>>>

Load the cluster CA certificate. Returns None if not bootstrapped.

impl ClusterCatalog

pub fn save_ghosts( &self, vshard_id: u32, ghost_table: &GhostTable, ) -> Result<()>

Persist ghost stubs for a vShard.

Called after each sweep or after ghost table mutations to ensure refcounts survive crash/restart.

pub fn load_ghosts(&self, vshard_id: u32) -> Result<Option<GhostTable>>

Load ghost stubs for a vShard. Returns None if no ghosts persisted.

pub fn load_all_ghosts(&self) -> Result<Vec<(u32, GhostTable)>>

Load all persisted ghost tables across all vShards.

Returns (vshard_id, GhostTable) pairs for all vShards that have ghosts.

pub fn delete_ghosts(&self, vshard_id: u32) -> Result<()>

Delete persisted ghosts for a vShard (after all ghosts purged).

impl ClusterCatalog

pub fn save_topology(&self, topology: &ClusterTopology) -> Result<()>

Persist the cluster topology.

pub fn load_topology(&self) -> Result<Option<ClusterTopology>>

Load the cluster topology. Returns None if no topology has been saved.

pub fn save_routing(&self, routing: &RoutingTable) -> Result<()>

Persist the routing table.

pub fn load_routing(&self) -> Result<Option<RoutingTable>>

Load the routing table. Returns None if no routing table has been saved.