Struct InboundConnectorLink 

pub struct InboundConnectorLink {
    pub url: LinkAddress,
    pub config: Vec<(String, String)>,
    pub ingest_factory: IngestFactoryFn,
    pub topic_resolver: Option<TopicResolverFn>,
}

Configuration for an inbound connector link (External → AimDB)

Stores the parsed URL, configuration, and the fused ingest factory. The factory captures the type T at creation time, allowing type-safe deserialize+produce later without needing PhantomData or type parameters.

Fields

url: LinkAddress

Parsed link address (scheme://resource)

config: Vec<(String, String)>

Additional configuration options (protocol-specific)

ingest_factory: IngestFactoryFn

Fused ingest factory (alloc feature)

Takes the live AimDb and returns the IngestFn that deserializes bytes and produces into the record’s buffer in one typed closure. Captures the record type T at link_from() call time — finish() validates the deserializer is present before registering the link, so the factory is always set.

Available in both std and no_std + alloc environments.

topic_resolver: Option<TopicResolverFn>

Optional dynamic topic resolver (late-binding)

Called once at connector startup to determine the subscription topic. If the resolver returns None, the static topic from the URL is used.

Available in both std and no_std + alloc environments.

Implementations

impl InboundConnectorLink

pub fn new(url: LinkAddress, ingest_factory: IngestFactoryFn) -> Self

Creates a new inbound connector link from a link address and ingest factory

pub fn create_ingest(&self, db: &AimDb) -> IngestFn

Creates the fused ingest callback using the stored factory.

Runs once at route-collection time; the returned IngestFn is the per-message path (deserialize + produce, no erasure crossing).

Available in both std and no_std + alloc environments.

pub fn resolve_topic(&self) -> String

Resolves the subscription topic for this link

If a topic resolver is configured, calls it to determine the topic. Otherwise, returns the static topic from the URL.

This is called once at connector startup.

Trait Implementations

impl Clone for InboundConnectorLink

fn clone(&self) -> InboundConnectorLink

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.