Struct Continuum 

pub struct Continuum { /* private fields */ }

Sorted-by-server-order continuum.

Examples

use dynomite::hashkit::modula::{Continuum, ServerSpec};
let c = Continuum::build(&[ServerSpec { name: "a".into(), weight: 2 }]).unwrap();
assert_eq!(c.len(), 2);

Implementations

impl Continuum

pub fn build(servers: &[ServerSpec]) -> Result<Self, DynError>

Build the continuum from servers. Every server contributes weight consecutive slots in declaration order.

Errors

Currently never fails; the signature returns Result so the distribution interface stays consistent with ketama.

Examples

use dynomite::hashkit::modula::{Continuum, ServerSpec};
let c = Continuum::build(&[
    ServerSpec { name: "a".into(), weight: 3 },
    ServerSpec { name: "b".into(), weight: 1 },
]).unwrap();
assert_eq!(c.len(), 4);

pub fn slots(&self) -> &[Slot]

Read-only view of the slots in their canonical order.

Examples

use dynomite::hashkit::modula::{Continuum, ServerSpec};
let c = Continuum::build(&[ServerSpec { name: "a".into(), weight: 2 }]).unwrap();
assert_eq!(c.slots().len(), 2);

pub fn len(&self) -> usize

Number of slots.

Examples

use dynomite::hashkit::modula::Continuum;
assert_eq!(Continuum::default().len(), 0);

pub fn is_empty(&self) -> bool

Whether the continuum is empty.

Examples

use dynomite::hashkit::modula::Continuum;
assert!(Continuum::default().is_empty());

pub fn dispatch(&self, hash: u32) -> Result<usize, DynError>

Map a 32-bit hash to a server index using hash % len.

Errors

Returns an error when the continuum is empty.

Examples

use dynomite::hashkit::modula::{Continuum, ServerSpec};
let c = Continuum::build(&[
    ServerSpec { name: "a".into(), weight: 1 },
    ServerSpec { name: "b".into(), weight: 1 },
]).unwrap();
assert_eq!(c.dispatch(2).unwrap(), 0);
assert_eq!(c.dispatch(3).unwrap(), 1);

Trait Implementations

impl Clone for Continuum

fn clone(&self) -> Continuum

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Continuum

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

Formats the value using the given formatter.

impl Default for Continuum

fn default() -> Continuum

Returns the “default value” for a type.