Struct FieldHashBucketRouting 

pub struct FieldHashBucketRouting<M, T, H>
where
    T: Hash,
    H: BuildHasher + Clone,
{ /* private fields */ }

A router using consistent hashing on some field of the message

Changing the membership is supported, but will result in bucket reassignments.

Implementations

impl<M, T, H> FieldHashBucketRouting<M, T, H>

where T: Hash, H: BuildHasher + Clone,

pub fn new( hasher_builder: H, field_extractor: fn(&M) -> &T, ) -> FieldHashBucketRouting<M, T, H>

Create a new instance of this router using the provided hasher and field extractor function

pub fn hash_field(&self, field: &T) -> u64

Hashes the field using this router’s Hasher

pub fn hash_message(&self, msg: &M) -> u64

Extracts and hashes the msg field using this router’s Hasher

pub fn get_bucket(&self, msg: &M, length: usize) -> usize

Provides the bucket index for the msg for length buckets

It does so by calling hash_message internally and then using modulo arithmentic to decide a bucket from the hash.

Trait Implementations

impl<M, T, H> Clone for FieldHashBucketRouting<M, T, H>

where T: Hash, H: BuildHasher + Clone,

fn clone(&self) -> FieldHashBucketRouting<M, T, H>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M, T, H> Debug for FieldHashBucketRouting<M, T, H>

where T: Hash, H: BuildHasher + Clone,

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

Formats the value using the given formatter.

impl<H> Default for FieldHashBucketRouting<NetMessage, ActorPath, H>

where H: BuildHasher + Default + Clone,

fn default() -> FieldHashBucketRouting<NetMessage, ActorPath, H>

Returns the “default value” for a type.

impl<H> RoutingPolicy<DynActorRef, NetMessage> for FieldHashBucketRouting<NetMessage, ActorPath, H>

where H: BuildHasher + Clone + Send + Sync + 'static,

fn route( &self, members: &[&DynActorRef], msg: NetMessage, logger: &Logger<Arc<Fuse<Async>>>, )

Route the msg to the appropriate members

fn boxed_clone( &self, ) -> Box<dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync>

Create a boxed copy of this policy

fn broadcast( &self, ) -> Option<&(dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync)>

Provide the broadcast part of this policy, if any

fn select( &self, ) -> Option<&(dyn RoutingPolicy<DynActorRef, NetMessage> + Send + Sync)>

Provide the select part of this policy, if any

impl<M, T, H> Copy for FieldHashBucketRouting<M, T, H>

where T: Hash, H: BuildHasher + Clone + Copy,