Struct scylla::routing::ShardInfo

pub struct ShardInfo { /* fields omitted */ }

Implementations

impl ShardInfo

pub fn new(shard: u16, nr_shards: u16, 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_token(&self, t: Token) -> u16

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

Trait Implementations

impl Clone for ShardInfo

fn clone(&self) -> ShardInfo

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ShardInfo

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

Formats the value using the given formatter.

impl Eq for ShardInfo

impl PartialEq<ShardInfo> for ShardInfo

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl StructuralEq for ShardInfo

impl StructuralPartialEq for ShardInfo

impl<'a> TryFrom<&'a HashMap<String, Vec<String>, RandomState>> for ShardInfo

type Error = Error

The type returned in the event of a conversion error.

fn try_from(
    options: &'a HashMap<String, Vec<String>>
) -> Result<Self, Self::Error>

Performs the conversion.