Struct QueueRouter 

pub struct QueueRouter { /* private fields */ }

Registry for named queue backends (multi-backend hosts).

Implementations

impl QueueRouter

pub fn new() -> QueueRouter

Empty registry.

pub fn with_default(backend: Arc<dyn QueueBackend>) -> QueueRouter

Register a single default backend under DEFAULT_BACKEND_NAME.

pub fn register(&mut self, name: &str, backend: Arc<dyn QueueBackend>)

Register during initial setup (mutable bootstrap).

Panics

Panics if the internal lock is poisoned.

pub fn register_runtime( &self, name: &str, backend: Arc<dyn QueueBackend>, ) -> Result<(), BosonError>

Register after Self::set_global (runtime registration).

Errors

Returns BosonError::Internal if the lock is poisoned.

pub fn resolve(&self, name: &str) -> Result<Arc<dyn QueueBackend>, BosonError>

Resolve a backend by logical name.

Errors

Returns BosonError::Internal if the lock is poisoned, or BosonError::UnknownBackend when name is not registered.

pub fn set_global(router: QueueRouter)

Install the process-global router (call once at host boot).

pub fn global() -> Arc<QueueRouter>

Global router (panics if Self::set_global was not called).

Panics

Panics when Self::set_global was not called before this function.

pub fn try_global() -> Option<Arc<QueueRouter>>

Optional global router.

Trait Implementations

impl Debug for QueueRouter

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

Formats the value using the given formatter.

impl Default for QueueRouter

fn default() -> QueueRouter

Returns the “default value” for a type.