Trait MessageExtractor 

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

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

Required Associated Types

type Message: Send + 'static

Required Methods

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

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

Implementors