Struct ConsistentHash 

pub struct ConsistentHash<K> { /* private fields */ }

Stable ring selection over explicit member-token evidence.

Each eligible member contributes a positive fixed number of deterministic virtual points. A key selects the first clockwise point, wrapping at the ring end. Unknown members are ineligible; evidence rejection is atomic. Token and key hashes are application/System facts supplied through concrete functions and observations. Tokens are policy data, never actor identities or freshness evidence. Ring mixing, clockwise tie order, and replica count are deliberate Bombay policy; no external hash-routing crate is used. Router owns recipient identity and order; this policy retains only the corresponding versioned token evidence.

Implementations

impl<K> ConsistentHash<K>

pub const fn new(replicas: NonZeroU16, hash_key: fn(&K) -> u64) -> Self

Construct a stable-ring policy with explicit virtual-point count.

Trait Implementations

impl<K> Clone for ConsistentHash<K>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Route, K> RoutingStrategy<Route> for ConsistentHash<K>

where Route: DeliveryRoute + Clone + PartialEq, <Route::Protocol as Protocol>::Msg: RouteKey<K>,

type Observation = MemberTokenObservation<Route>

Closed observation type accepted by this policy.

type Error = MemberEvidenceError

Concrete observation rejection reason.

fn select( &mut self, members: &[Route], message: &<Route::Protocol as Protocol>::Msg, ) -> Option<usize>

Select at most one index from this exact typed membership snapshot.

fn observe( &mut self, members: &[Route], observation: Self::Observation, ) -> Result<(), RoutingObservationRejection<Self::Observation, Self::Error>>

Fold one typed observation against the same membership snapshot.

fn added(&mut self, _: Route)

Update policy-local state after one new membership is committed.

fn removed(&mut self, index: usize, _: Route, _: usize)

Repair policy-local position after a membership removal.