Struct Ring

pub struct Ring { /* private fields */ }

Implementations

impl Ring

pub fn new(config: Config) -> Self

Examples found in repository

examples/ring.rs (line 4)

fn main() {
    let mut r = Ring::new(Config::default());

    r.add("1.1.1.1");
    r.add("2.2.2.2");
    r.add("3.3.3.3");

    println!("{:?}", r.get("1.1.1.1"));
    println!("{:?}", r.get("8.8.8.8"));
    println!("{:?}", r.get("/foo"));
    println!("{:?}", r.get("/bar"));
}

pub fn replication_factor(&self) -> u64

pub fn add(&mut self, hostname: &str)

Adds a new host to the ring. If the host already added, ignore.

Examples found in repository

examples/ring.rs (line 6)

fn main() {
    let mut r = Ring::new(Config::default());

    r.add("1.1.1.1");
    r.add("2.2.2.2");
    r.add("3.3.3.3");

    println!("{:?}", r.get("1.1.1.1"));
    println!("{:?}", r.get("8.8.8.8"));
    println!("{:?}", r.get("/foo"));
    println!("{:?}", r.get("/bar"));
}

pub fn remove(&mut self, hostname: &str)

Removes host from the ring.

pub fn get(&mut self, key: &str) -> Option<String>

Locates a host for the key.

Examples found in repository

examples/ring.rs (line 10)

fn main() {
    let mut r = Ring::new(Config::default());

    r.add("1.1.1.1");
    r.add("2.2.2.2");
    r.add("3.3.3.3");

    println!("{:?}", r.get("1.1.1.1"));
    println!("{:?}", r.get("8.8.8.8"));
    println!("{:?}", r.get("/foo"));
    println!("{:?}", r.get("/bar"));
}

pub fn get_least(&mut self, key: &str) -> Option<String>

Picks the least load host for the key.

pub fn hosts(&mut self) -> Vec<String>

Lists all hosts in the ring.

pub fn set_load(&mut self, hostname: &str, load: u64)

Sets the load of host to the given value.

pub fn inc_load(&mut self, hostname: &str)

Increments the load of host by 1.

pub fn decr_load(&mut self, hostname: &str)

Decrements the load of host by 1.

pub fn avg_load(&self) -> f64

Gets the average load of ring.

Trait Implementations

impl Send for Ring

impl Sync for Ring