Struct ShardManager 

pub struct ShardManager { /* private fields */ }

Shard manager for handling sharding operations

Implementations

impl ShardManager

pub fn new(config: ShardingConfig) -> Self

Create a new shard manager

pub fn initialize(&mut self, nodes: Vec<String>) -> Result<()>

Initialize sharding with available nodes

pub fn find_shard(&self, key: &str) -> Result<String>

Find the shard for a given key

pub fn get_node_for_key(&self, key: &str) -> Result<String>

Get the node responsible for a key

pub fn add_node(&mut self, node_id: String) -> Result<()>

Add a new node to the cluster

pub fn remove_node(&mut self, node_id: &str) -> Result<()>

Remove a node from the cluster

pub fn migrate_shard( &mut self, shard_id: &str, target_node: Option<String>, ) -> Result<String>

Migrate a shard to a different node

pub fn complete_migration(&mut self, migration_id: &str) -> Result<()>

Complete a migration

pub fn get_stats(&self) -> ShardingStats

Get sharding statistics

pub fn list_shards(&self) -> Vec<DataShard>

List all shards

pub fn get_shard(&self, shard_id: &str) -> Option<DataShard>

Get shard by ID

pub fn update_shard_stats( &mut self, shard_id: &str, size_bytes: u64, key_count: usize, ) -> Result<()>

Update shard statistics

Trait Implementations

impl Debug for ShardManager

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

Formats the value using the given formatter.