Struct SlotManager 

pub struct SlotManager { /* private fields */ }

Enables local workers to make themselves visible to a shared client instance. There can only be one worker registered per namespace+queue_name+client, others will get ignored. It also provides a convenient method to find compatible slots within the collection.

Implementations

impl SlotManager

pub fn new() -> Self

Factory method.

pub fn register( &self, provider: Box<dyn SlotProvider + Send + Sync>, ) -> Option<WorkerKey>

Register a local worker that can provide WFT processing slots.

pub fn unregister( &self, id: WorkerKey, ) -> Option<Box<dyn SlotProvider + Send + Sync>>

Unregister a provider, typically when its worker starts shutdown.

Trait Implementations

impl Debug for SlotManager

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

Formats the value using the given formatter.

impl Default for SlotManager

fn default() -> SlotManager

Returns the “default value” for a type.