Struct PartitionManager 

pub struct PartitionManager { /* private fields */ }

Partition manager for data distribution

Implementations

impl PartitionManager

pub fn new(replication_factor: usize) -> Self

Create a new partition manager

pub async fn add_node(&self, node_id: NodeId) -> Result<(), PartitionError>

Add a node to the partition ring

pub async fn remove_node(&self, node_id: &NodeId) -> Result<(), PartitionError>

Remove a node from the partition ring

pub async fn get_nodes_for_key(&self, key: &[u8]) -> Vec<NodeId>

Get nodes responsible for a key

pub async fn get_partition_for_key(&self, key: &[u8]) -> PartitionId

Get partition for a key

pub async fn get_partitions_for_node( &self, node_id: &NodeId, ) -> Vec<PartitionId>

Get all partitions assigned to a node

pub async fn is_node_responsible(&self, node_id: &NodeId, key: &[u8]) -> bool

Check if a node is responsible for a key

pub async fn get_distribution_stats(&self) -> PartitionStats

Get partition distribution statistics

pub async fn rebalance(&self) -> Result<(), PartitionError>

Rebalance partitions after node changes