Struct Sharder

pub struct Sharder {
    pub nr_shards: ShardCount,
    pub msb_ignore: u8,
}

Fields

nr_shards: ShardCount

msb_ignore: u8

Implementations

impl Sharder

pub fn new(nr_shards: ShardCount, msb_ignore: u8) -> Self

pub fn shard_of(&self, token: Token) -> Shard

pub fn shard_of_source_port(&self, source_port: u16) -> Shard

If we connect to Scylla using Scylla’s shard aware port, then Scylla assigns a shard to the connection based on the source port. This calculates the assigned shard.

pub fn draw_source_port_for_shard(&self, shard: Shard) -> u16

Randomly choose a source port p such that shard == shard_of_source_port(p).

pub fn iter_source_ports_for_shard( &self, shard: Shard, ) -> impl Iterator<Item = u16>

Returns iterator over source ports p such that shard == shard_of_source_port(p). Starts at a random port and goes forward by nr_shards. After reaching maximum wraps back around. Stops once all possible ports have been returned

Trait Implementations

impl Clone for Sharder

fn clone(&self) -> Sharder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Sharder

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

Formats the value using the given formatter.

impl PartialEq for Sharder

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Sharder

impl StructuralPartialEq for Sharder