Struct ShardAssignment 

pub struct ShardAssignment {
    pub num_shards: usize,
    pub buckets: Vec<Vec<String>>,
}

Result of running ModelShardManager::partition over a known set of IDs.

A ShardAssignment is a vector of num_shards buckets, where each bucket holds the IDs that map to that shard. Bucket ordering follows the input order so the assignment is stable for a given input + num_shards pair.

Fields

num_shards: usize

Number of shards (length of buckets).

buckets: Vec<Vec<String>>

buckets[i] is the list of IDs that map to shard i.

Implementations

impl ShardAssignment

pub fn total(&self) -> usize

Total number of IDs across all shards.

pub fn shard_of(&self, id: &str) -> Option<usize>

Look up which shard an ID was assigned to, or None if it isn’t present.

Trait Implementations

impl Clone for ShardAssignment

fn clone(&self) -> ShardAssignment

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShardAssignment

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ShardAssignment

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ShardAssignment

impl PartialEq for ShardAssignment

fn eq(&self, other: &ShardAssignment) -> 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 Serialize for ShardAssignment

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ShardAssignment