Struct PartitionTable 

pub struct PartitionTable {
    pub partition_count: u32,
    /* private fields */
}

Partition assignment table

Fields

partition_count: u32

Total number of partitions

Implementations

impl PartitionTable

pub fn new(partition_count: u32, nodes: &[ClusterNode]) -> Self

Create a new partition table and assign partitions to nodes.

pub fn owner_of(&self, partition_index: u32) -> Option<&str>

Look up the owner of a partition.

pub fn partitions_for_node<'a>(&'a self, node_id: &str) -> Vec<&'a Partition>

Return all partitions owned by a given node.

pub fn rebalance(&mut self, nodes: &[ClusterNode])

Rebalance by rebuilding the ring after node changes.