Trait elfo_core::routers::Router

pub trait Router<C>: Send + Sync + 'static {
    type Key: Clone + Hash + Eq + Display + Send + Sync;

    // Required method
    fn route(&self, envelope: &Envelope) -> Outcome<Self::Key>;

    // Provided method
    fn update(&self, _config: &C) { ... }
}

Required Associated Types

type Key: Clone + Hash + Eq + Display + Send + Sync

Required Methods

fn route(&self, envelope: &Envelope) -> Outcome<Self::Key>

Provided Methods

fn update(&self, _config: &C)

Implementations on Foreign Types

impl<C> Router<C> for ()

type Key = Singleton

fn route(&self, envelope: &Envelope) -> Outcome<Self::Key>

Implementors

impl<C, R, K> Router<C> for MapRouter<C, (), (), R>where C: Send + Sync + 'static, R: Fn(&Envelope) -> Outcome<K> + Send + Sync + 'static, K: Clone + Hash + Eq + Display + Send + Sync,

type Key = K

impl<C, S, P, R, K> Router<C> for MapRouter<C, ArcSwap<S>, P, R>where C: Send + Sync + 'static, S: Send + Sync + 'static, R: Fn(&Envelope, &S) -> Outcome<K> + Send + Sync + 'static, P: Fn(&C, &S) -> S + Send + Sync + 'static, K: Clone + Hash + Eq + Display + Send + Sync,

type Key = K