Struct ShardRouter 

pub struct ShardRouter { /* private fields */ }

Maps application keys onto a fixed number of shards with a stable hash.

Implementations

impl ShardRouter

pub fn new(shard_count: u32) -> Self

A router over shard_count shards (clamped to [1, MAX_VIRTUAL_SHARDS]).

pub fn shard_count(&self) -> u32

The number of shards this router partitions keys into.

pub fn shard_for(&self, key: &[u8]) -> ShardId

The shard owning key, by stable hash modulo the shard count.

pub fn expand_shard_count( &mut self, new_count: u32, ) -> Result<ShardCountExpansionPlan, ShardExpansionError>

Increase the active shard count (operator-driven expansion). Keys remap when the modulus changes — drain clients before applying.

Errors

Returns an error when new_count shrinks the space or exceeds MAX_VIRTUAL_SHARDS.

Trait Implementations

impl Clone for ShardRouter

fn clone(&self) -> ShardRouter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for ShardRouter

impl Debug for ShardRouter

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

Formats the value using the given formatter.

impl Eq for ShardRouter

impl PartialEq for ShardRouter

fn eq(&self, other: &ShardRouter) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ShardRouter