Struct RoundRobinRouting 

pub struct RoundRobinRouting { /* private fields */ }

Round-robin dispatch policy

This policy can handle changing membership, but won’t start a new round immediately on change.

Implementations

impl RoundRobinRouting

pub fn new() -> RoundRobinRouting

Create a new instance starting at index 0

pub fn get_and_increment_index(&self, length: usize) -> usize

Get and return the current index and increment it for the next invocation

Trait Implementations

impl Debug for RoundRobinRouting

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

Formats the value using the given formatter.

impl Default for RoundRobinRouting

fn default() -> RoundRobinRouting

Returns the “default value” for a type.

impl RoutingPolicy<DynActorRef, NetMessage> for RoundRobinRouting

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