Struct Rack 

pub struct Rack { /* private fields */ }

One rack within a datacenter.

continuums is sorted by token in ascending order to support vnode_dispatch’s binary search; callers append continuum points and call Rack::sort_continuums once after a batch of updates.

Implementations

impl Rack

pub fn new(name: String, dc: String) -> Self

Build an empty rack.

Examples

use dynomite::cluster::datacenter::Rack;
let r = Rack::new("rack1".into(), "dc1".into());
assert_eq!(r.name(), "rack1");
assert_eq!(r.dc(), "dc1");
assert!(r.continuums().is_empty());

pub fn name(&self) -> &str

Rack name.

pub fn dc(&self) -> &str

Owning datacenter name.

pub fn continuums(&self) -> &[Continuum]

Borrow the continuum points (sorted by token).

pub fn nserver_continuum(&self) -> u32

Number of distinct servers ever added (mirrors the C reference’s nserver_continuum).

pub fn ncontinuum(&self) -> u32

Number of continuum points (mirrors ncontinuum).

pub fn add_peer_tokens(&mut self, peer_idx: u32, tokens: &[DynToken])

Append continuum points produced from one peer’s tokens.

Examples

use dynomite::cluster::datacenter::{Continuum, Rack};
use dynomite::hashkit::DynToken;
let mut r = Rack::new("rack1".into(), "dc1".into());
r.add_peer_tokens(0, &[DynToken::from_u32(2), DynToken::from_u32(5)]);
assert_eq!(r.ncontinuum(), 2);
assert_eq!(r.nserver_continuum(), 2);

pub fn sort_continuums(&mut self)

Sort the continuum by token (ascending). Callers must invoke this once after a batch of Rack::add_peer_tokens calls so that crate::cluster::vnode::dispatch can binary-search the ring.

Examples

use dynomite::cluster::datacenter::Rack;
use dynomite::hashkit::DynToken;
let mut r = Rack::new("r".into(), "d".into());
r.add_peer_tokens(0, &[DynToken::from_u32(5)]);
r.add_peer_tokens(1, &[DynToken::from_u32(2)]);
r.sort_continuums();
assert_eq!(r.continuums()[0].peer_idx, 1);

pub fn clear_continuums(&mut self)

Reset all continuum state for a fresh rebuild.

pub fn ring(&self) -> &RackRing

Borrow the rack’s ring representation.

pub fn set_random_slices(&mut self, slices: RandomSlices)

Install a RandomSlices table on this rack. The continuum stays populated so the shadow-distribution path (and any operator-side dump) can still walk the vnode view.

pub fn is_random_slicing(&self) -> bool

True when the rack’s live distribution is random slicing.

pub fn random_slices(&self) -> Option<&RandomSlices>

Borrow the rack’s RandomSlices table when one is installed.

Trait Implementations

impl Clone for Rack

fn clone(&self) -> Rack

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Rack

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

Formats the value using the given formatter.