Struct ConnectorLink 

pub struct ConnectorLink {
    pub url: LinkAddress,
    pub config: Vec<(String, String)>,
    pub source_factory: SourceFactoryFn,
}

Configuration for a connector link

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

Fields

url: LinkAddress

Parsed link address (scheme://resource)

config: Vec<(String, String)>

Additional configuration options (protocol-specific)

source_factory: SourceFactoryFn

Fused source factory (alloc feature)

Takes the live AimDb and returns the SerializedSource whose readers yield destination + payload directly (subscribe → recv → resolve topic → serialize, all typed inside). Captures the record type T at link_to() configuration time — finish() validates the serializer is present before registering the link, so the factory is always set.

Available in both std and no_std + alloc environments.

Implementations

impl ConnectorLink

pub fn new(url: LinkAddress, source_factory: SourceFactoryFn) -> Self

Creates a new connector link from a link address and source factory

pub fn create_source(&self, db: &AimDb) -> Box<dyn SerializedSource>

Creates the fused serialized source using the stored factory.

Runs once at route-collection time; the readers it hands out are the per-message path (no Box<dyn Any>).

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.