Struct InboundConnectorLink 

pub struct InboundConnectorLink {
    pub url: ConnectorUrl,
    pub config: Vec<(String, String)>,
    pub deserializer: DeserializerFn,
    pub producer_factory: Option<ProducerFactoryFn>,
}

Configuration for an inbound connector link (External → AimDB)

Stores the parsed URL, configuration, deserializer, and a producer creation callback. The callback captures the type T at creation time, allowing type-safe producer creation later without needing PhantomData or type parameters.

Fields

url: ConnectorUrl

Parsed connector URL

config: Vec<(String, String)>

Additional configuration options (protocol-specific)

deserializer: DeserializerFn

Deserialization callback that converts bytes to typed values

This is a type-erased function that takes &[u8] and returns Result<Box<dyn Any + Send>, String>. The spawned task will downcast to the concrete type before producing.

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

producer_factory: Option<ProducerFactoryFn>

Producer creation callback (alloc feature)

Takes Arc<AimDb> and returns Box. Captures the record type T at link_from() call time.

Available in both std and no_std + alloc environments.

Implementations

impl InboundConnectorLink

pub fn new(url: ConnectorUrl, deserializer: DeserializerFn) -> Self

Creates a new inbound connector link from a URL and deserializer

pub fn with_producer_factory<F>(self, factory: F) -> Self

where F: Fn(Arc<dyn Any + Send + Sync>) -> Box<dyn ProducerTrait> + Send + Sync + 'static,

Sets the producer factory callback (alloc feature)

Available in both std and no_std + alloc environments.

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

Creates a producer using the stored factory (alloc feature)

Available in both std and no_std + alloc environments.

Trait Implementations

impl Clone for InboundConnectorLink

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InboundConnectorLink

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

Formats the value using the given formatter.