Skip to main content

atomr_cluster_sharding/
extractor.rs

1//! `IMessageExtractor` equivalent from.
2
3pub trait MessageExtractor: Send + Sync + 'static {
4    type Message: Send + 'static;
5
6    fn entity_id(&self, message: &Self::Message) -> String;
7    fn shard_id(&self, message: &Self::Message) -> String;
8}