Struct ConnectorLink 

pub struct ConnectorLink {
    pub url: ConnectorUrl,
    pub config: Vec<(String, String)>,
    pub serializer: Option<SerializerFn>,
    pub consumer_factory: Option<ConsumerFactoryFn>,
}

Configuration for a connector link

Stores the parsed URL and configuration until the record is built. The actual client creation and handler spawning happens during the build phase.

Fields

url: ConnectorUrl

Parsed connector URL

config: Vec<(String, String)>

Additional configuration options (protocol-specific)

serializer: Option<SerializerFn>

Serialization callback that converts record values to bytes for publishing

This is a type-erased function that takes &dyn Any and returns Result<Vec<u8>, String>. The connector implementation will downcast to the concrete type and call the serializer.

If None, the connector must provide a default serialization mechanism or fail.

Available in both std and no_std (with alloc feature) environments.

consumer_factory: Option<ConsumerFactoryFn>

Consumer factory callback (alloc feature)

Creates ConsumerTrait from Arc<AimDb> to enable type-safe subscription. The factory captures the record type T at link_to() configuration time, allowing the connector to subscribe without knowing T at compile time.

Mirrors the producer_factory pattern used for inbound connectors.

Available in both std and no_std + alloc environments.

Implementations

impl ConnectorLink

pub fn new(url: ConnectorUrl) -> Self

Creates a new connector link from a URL

pub fn with_config( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Adds a configuration option

pub fn create_consumer( &self, db_any: Arc<dyn Any + Send + Sync>, ) -> Option<Box<dyn ConsumerTrait>>

Creates a consumer using the stored factory (alloc feature)

Takes an Arc (which should contain Arc<AimDb>) and invokes the consumer factory to create a ConsumerTrait instance.

Returns None if no factory is configured.

Available in both std and no_std + alloc environments.

Trait Implementations

impl Clone for ConnectorLink

fn clone(&self) -> ConnectorLink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectorLink

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

Formats the value using the given formatter.