Struct ShardingRouter 

pub struct ShardingRouter { /* private fields */ }

分片路由器

根据 ShardingStrategy 将 key 路由到对应的 shard。 v0.3.0 起支持 Enum/List/Directory/Composite 等新策略。

Implementations

impl ShardingRouter

pub fn new(strategy: ShardingStrategy, shards: Vec<&str>) -> Self

创建路由器（兼容旧 API：传入策略与 shard 列表）

pub fn new_enum( mapping: HashMap<String, String>, default: Option<String>, ) -> Self

构造枚举分片路由器

pub fn new_list( keys: HashSet<String>, target: String, default: Option<String>, ) -> Self

构造列表分片路由器

pub fn new_directory(table: HashMap<String, String>) -> Self

构造目录分片路由器

pub fn new_composite( primary: ShardingStrategy, primary_shards: Vec<String>, secondary: ShardingStrategy, secondary_shards: Vec<String>, ) -> Self

构造复合分片路由器

pub fn route(&self, key: &str) -> Result<&str, ShardingError>

根据 key 路由到对应的 shard

Errors

• Hash/Range/Date 策略下 shards 为空时返回 ShardingError::NoShardsConfigured
• Enum/List/Directory 策略未匹配且无默认时返回 ShardingError::NoMappingForKey

pub fn route_by_data( &self, data: &dyn Any, extractor: &dyn ShardKeyExtractor, ) -> Result<&str, ShardingError>

通过数据对象 + 提取器路由：先从 data 提取 key，再 route(key)

Errors

提取失败或路由失败时返回对应 ShardingError。

pub fn query_all(&self) -> &[String]

返回所有 shard（用于广播查询；仅 Hash/Range/Date 有效）

pub fn strategy(&self) -> ShardingStrategy

返回当前策略（克隆）

pub fn shard_count(&self) -> usize

返回 shard 数量