Struct TransportRegistry 

pub struct TransportRegistry {
    Transports: HashMap<String, Arc<dyn CommonTransportStrategy>>,
    Active: Option<String>,
    Selector: TransportSelector,
}

Central registry for managing transport strategies.

Fields

Transports: HashMap<String, Arc<dyn CommonTransportStrategy>>

Registered transports (name -> Arc<dyn CommonTransportStrategy>)

Active: Option<String>

Currently active transport name

Selector: TransportSelector

Transport selector for auto-selection

Implementations

impl TransportRegistry

pub fn New() -> Self

Creates a new, empty transport registry.

pub fn WithSelector(Selector: TransportSelector) -> Self

Creates a new registry with a custom selector.

pub fn Register( &mut self, Name: String, Transport: Arc<dyn CommonTransportStrategy>, )

Registers a new transport with the registry.

pub async fn Unregister(&mut self, Name: &str) -> Result<(), TransportError>

Unregisters a transport from the registry.

pub async fn Select(&mut self, Name: &str) -> Result<(), TransportError>

Selects a transport by name as the active transport.

pub async fn AutoSelect( &mut self, Context: &TransportContext, ) -> Result<String, TransportError>

Automatically selects the best transport based on the provided context.

pub fn GetActive(&self) -> Option<Arc<dyn CommonTransportStrategy>>

Gets the currently active transport, if any.

pub fn Get(&self, Name: &str) -> Option<Arc<dyn CommonTransportStrategy>>

Gets a specific transport by name.

pub fn List(&self) -> Vec<String>

Lists all registered transport names.

pub fn Has(&self, Name: &str) -> bool

Checks if a transport with the given name is registered.

pub fn GetAllMetrics(&self) -> HashMap<String, TransportMetrics>

Gets metrics for all registered transports.

pub fn GetHealthStatus(&self) -> HashMap<String, bool>

Gets health status (connected/not connected) for all transports.

pub fn ActiveName(&self) -> Option<&str>

Gets the name of the currently active transport.

pub fn SetSelector(&mut self, Selector: TransportSelector)

Sets the selector to use for auto-selection.

pub async fn WaitForReady( &self, Name: &str, Timeout: Duration, ) -> Result<(), TransportError>

Waits for a transport to be ready (connected) with timeout.

Trait Implementations

impl Default for TransportRegistry

fn default() -> Self

Returns the “default value” for a type.