Struct VnodeRegistry 

pub struct VnodeRegistry { /* private fields */ }

Runtime registry of vnode topology and assignment.

Implementations

impl VnodeRegistry

pub fn new(vnode_count: u32) -> Self

Create a registry sized for vnode_count vnodes, all marked as NodeId::UNASSIGNED. The assignment version starts at 1.

Panics

Panics if vnode_count == 0.

pub fn single_owner(vnode_count: u32, owner: NodeId) -> Self

Create a registry where every vnode is owned by the same node.

Used by single-instance / embedded deployments.

Panics

Panics if vnode_count == 0.

pub fn vnode_count(&self) -> u32

Number of vnodes.

pub fn assignment_version(&self) -> u64

Current monotonic assignment version.

pub fn owner(&self, vnode: u32) -> NodeId

Owner of a given vnode. Returns NodeId::UNASSIGNED if the vnode is out of range or unassigned.

pub fn snapshot(&self) -> Arc<[NodeId]>

Snapshot the current assignment vector. Cheap — internally an Arc::clone.

pub fn set_assignment(&self, new_assignment: Arc<[NodeId]>)

Replace the full assignment and bump the version.

Panics

Panics if new_assignment.len() != self.vnode_count.

pub fn set_assignment_and_version( &self, new_assignment: Arc<[NodeId]>, version: u64, )

Replace the full assignment and set the version to version atomically. For recovery paths that must restore the registry to a persisted fence generation, not a fresh bump.

Panics

Panics on length mismatch, or if version is less than the current one (assignment versions are monotonic).

pub fn vnode_for_key(&self, key: &[u8]) -> u32

Map a primary key to a vnode.

Trait Implementations

impl Debug for VnodeRegistry

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

Formats the value using the given formatter.