Struct ClusterState 

pub struct ClusterState { /* private fields */ }

Decoupled view of cluster topology + liveness.

Carries enough state for the APL walker to compute an annotated preference list without consulting the live pool:

• a sorted-by-token continuum of (token, peer_id) ring points (one entry per vnode, may have several entries per peer);
• the set of peers currently alive according to the failure detector.

The ring is held as-passed; the constructor sorts it by token.

Implementations

impl ClusterState

pub fn new(ring: Vec<RingPoint>, alive: HashSet<PeerId>) -> Self

Build a ClusterState from a ring and a liveness set.

The ring is sorted by token (ties broken by peer id) so callers can pass any ordering without thinking about it. Empty rings are accepted; get_apl_ann will return an empty vector for them.

Examples

use dynomite::cluster::apl::{ClusterState, RingPoint};
let cs = ClusterState::new(
    vec![RingPoint::new(2, 1), RingPoint::new(1, 0)],
    [0u32, 1].into_iter().collect(),
);
assert_eq!(cs.ring()[0].token, 1);

pub fn ring(&self) -> &[RingPoint]

Read-only view of the sorted ring.

pub fn is_alive(&self, peer_id: PeerId) -> bool

True when peer_id is in the alive set.

Examples

use dynomite::cluster::apl::{ClusterState, RingPoint};
let cs = ClusterState::new(
    vec![RingPoint::new(1, 0)],
    [0u32].into_iter().collect(),
);
assert!(cs.is_alive(0));
assert!(!cs.is_alive(99));

Trait Implementations

impl Clone for ClusterState

fn clone(&self) -> ClusterState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClusterState

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

Formats the value using the given formatter.