Struct AdvancedPartitioning 

pub struct AdvancedPartitioning { /* private fields */ }

Advanced partitioning manager

Implementations

impl AdvancedPartitioning

pub fn new(config: PartitionConfig) -> Self

Create a new partitioning manager

pub async fn register_node(&self, node_id: OxirsNodeId)

Register a node in the partitioning system

pub async fn unregister_node(&self, node_id: OxirsNodeId)

Remove a node from the partitioning system

pub fn hash_key(key: &str) -> u64

Hash a key for consistent hashing

pub async fn get_partition_assignment( &self, key: &str, ) -> Option<PartitionAssignment>

Get partition assignment for a key (consistent hashing)

pub async fn update_partition_stats(&self, key: &str, size_delta: isize)

Update partition statistics (call after data operations)

pub async fn get_node_partitions(&self, node_id: OxirsNodeId) -> Vec<usize>

Get all partition assignments for a node

pub async fn get_stats(&self) -> PartitioningStats

Get partition statistics

pub async fn get_virtual_nodes(&self) -> Vec<VirtualNode>

Get all virtual nodes (for debugging/monitoring)

pub async fn get_range_partitions(&self) -> Vec<RangePartition>

Get all range partitions

pub async fn check_rebalancing_needed(&self) -> bool

Check if rebalancing is needed

pub async fn perform_rebalancing(&self)

Perform rebalancing if needed

pub async fn clear(&self)

Clear all data

pub async fn get_load_distribution(&self) -> BTreeMap<OxirsNodeId, f64>

Get load distribution (percentage of data per node)