atomr-cluster-sharding 0.9.2

Sharded entities for atomr — allocation strategies, rebalance, three-phase handoff, remember-entities.
Documentation 
1
2
3
4
5
6
7
8

//! `IMessageExtractor` equivalent from.

pub trait MessageExtractor: Send + Sync + 'static {
    type Message: Send + 'static;

    fn entity_id(&self, message: &Self::Message) -> String;
    fn shard_id(&self, message: &Self::Message) -> String;
}