Struct CustomRouting 

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

Factory will dispatch to workers based on a custom hash function.

The factory maintains no queue in this scenario, and jobs are pushed to worker’s queues.

Implementations

impl<TKey, TMsg, THasher> CustomRouting<TKey, TMsg, THasher>

where TKey: JobKey, TMsg: Message, THasher: CustomHashFunction<TKey>,

pub fn new(hasher: THasher) -> CustomRouting<TKey, TMsg, THasher>

Construct a new CustomRouting instance with the supplied hash function

Trait Implementations

impl<TKey, TMsg, THasher> Debug for CustomRouting<TKey, TMsg, THasher>

where TKey: Debug + JobKey, TMsg: Debug + Message, THasher: Debug + CustomHashFunction<TKey>,

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

Formats the value using the given formatter.

impl<TKey, TMsg, THasher> Router<TKey, TMsg> for CustomRouting<TKey, TMsg, THasher>

where TKey: JobKey, TMsg: Message, THasher: CustomHashFunction<TKey> + 'static,

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)