Enum ConnectorClient 

pub enum ConnectorClient {
    Mqtt(Arc<dyn Any + Send + Sync>),
    Kafka(Arc<dyn Any + Send + Sync>),
    Http(Arc<dyn Any + Send + Sync>),
    Generic {
        protocol: String,
        client: Arc<dyn Any + Send + Sync>,
    },
}

Connector client types (type-erased for storage)

This enum allows storing different connector client types in a unified way. Actual protocol implementations will downcast to their concrete types.

Design Note

This is intentionally minimal - actual client types are defined by user extensions. The core only provides the infrastructure.

Works in both std and no_std (with alloc) environments.

Variants

Mqtt(Arc<dyn Any + Send + Sync>)

MQTT client (protocol-specific, user-provided)

Kafka(Arc<dyn Any + Send + Sync>)

Kafka producer (protocol-specific, user-provided)

Http(Arc<dyn Any + Send + Sync>)

HTTP client (protocol-specific, user-provided)

Generic

Generic connector for custom protocols

Fields

protocol: String

client: Arc<dyn Any + Send + Sync>

Implementations

impl ConnectorClient

pub fn downcast_ref<T: 'static>(&self) -> Option<&T>

Downcasts to a concrete client type

Example

use rumqttc::AsyncClient;

if let Some(mqtt_client) = connector.downcast_ref::<Arc<AsyncClient>>() {
    // Use the MQTT client
}

Trait Implementations

impl Clone for ConnectorClient

fn clone(&self) -> ConnectorClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConnectorClient

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

Formats the value using the given formatter.