Struct RoutingGroup 

pub struct RoutingGroup<'a> { /* private fields */ }

A routing group keeps group membership together with a routing policy

Implementations

impl<'a> RoutingGroup<'a>

pub fn new( members: Vec<&'a DynActorRef>, policy: &'a dyn RoutingPolicy<DynActorRef, NetMessage>, ) -> RoutingGroup<'a>

Create a new routing group

pub fn route(&self, msg: NetMessage, logger: &Logger<Arc<Fuse<Async>>>)

Route msg to our members as instructed by our policy

Trait Implementations

impl<'a> Debug for RoutingGroup<'a>

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

Formats the value using the given formatter.