atomr-core 0.1.0

Actors, supervision, dispatch, mailboxes, scheduler, FSM, event stream, and coordinated shutdown — the core of the atomr actor runtime.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Routers — distribute messages across a pool of routees.
//! akka.net: `src/core/Akka/Routing/`.
//!
//! We model a "routee" as any [`crate::actor::ActorRef<M>`] for a common
//! message type `M`. Each router type carries routing state and exposes a
//! single `route(msg)` entry point. For brevity here we expose 6 routing
//! logics — the full akka.net set.

mod broadcast;
mod consistent_hash;
mod random;
mod round_robin;
mod scatter_gather;
mod smallest_mailbox;
mod tail_chopping;

pub use broadcast::BroadcastRouter;
pub use consistent_hash::ConsistentHashRouter;
pub use random::RandomRouter;
pub use round_robin::RoundRobinRouter;
pub use scatter_gather::ScatterGatherFirstCompletedRouter;
pub use smallest_mailbox::SmallestMailboxRouter;
pub use tail_chopping::TailChoppingRouter;