Trait ShardRouter 

pub trait ShardRouter: Send + Sync {
    // Required method
    fn route(&self, meta: &RecordMeta, num_shards: usize) -> usize;
}

Routes records to shards. Pure and cheap — called per record on pipeline threads.

Required Methods

fn route(&self, meta: &RecordMeta, num_shards: usize) -> usize

The shard index in 0..num_shards for a record.

Implementors

impl ShardRouter for KeyHashRouter