Struct ConnectorLink 

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

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.

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

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.