Struct KeyPersistentRouting 

pub struct KeyPersistentRouting<TKey, TMsg>
where
    TKey: JobKey,
    TMsg: Message,
{ /* private fields */ }

Factory will select worker by hashing the job’s key. Workers will have jobs placed into their incoming message queue’s

Trait Implementations

impl<TKey, TMsg> Debug for KeyPersistentRouting<TKey, TMsg>

where TKey: Debug + JobKey, TMsg: Debug + Message,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<TKey, TMsg> Default for KeyPersistentRouting<TKey, TMsg>

where TKey: JobKey, TMsg: Message,

fn default() -> KeyPersistentRouting<TKey, TMsg>

Returns the “default value” for a type.

impl<TKey, TMsg> Router<TKey, TMsg> for KeyPersistentRouting<TKey, TMsg>

where TKey: JobKey, TMsg: Message,

fn route_message( &mut self, job: Job<TKey, TMsg>, pool_size: usize, worker_hint: Option<usize>, worker_pool: &mut HashMap<usize, WorkerProperties<TKey, TMsg>>, ) -> Result<RouteResult<TKey, TMsg>, Box<dyn Error + Send + Sync>>

Route a Job based on the specific routing methodology

fn choose_target_worker( &mut self, job: &Job<TKey, TMsg>, pool_size: usize, worker_hint: Option<usize>, _worker_pool: &HashMap<usize, WorkerProperties<TKey, TMsg>>, ) -> Option<usize>

Identifies if a job CAN be routed, and to which worker, without requiring dequeueing the job

fn is_factory_queueing(&self) -> bool

Returns a flag indicating if the factory does discard/overload management (true) or if is handled by the workers worker(s) (false)