Struct ConnectorConfig 

pub struct ConnectorConfig {
    pub timeout_ms: Option<u32>,
    pub protocol_options: Vec<(String, String)>,
}

Protocol-agnostic connector configuration

Carries the route’s key/value options to Connector::publish. Only the genuinely protocol-agnostic timeout_ms is a typed field; every protocol-specific knob (e.g. MQTT’s qos/retain) travels in protocol_options and is interpreted by the connector with its own defaults. Connector crates expose typed setters as extension traits over the link builders (e.g. the MQTT connector’s MqttLinkExt).

Fields

timeout_ms: Option<u32>

Optional timeout in milliseconds for the publish/operation, as interpreted by the connector

protocol_options: Vec<(String, String)>

Protocol-specific options as key-value pairs Allows custom configuration without polluting the base struct

Implementations

impl ConnectorConfig

pub fn from_query(query: &[(String, String)]) -> ConnectorConfig

Build a config from a route’s URL-query key/value pairs.

This is the shared seam the data-plane pump_sink helper uses to thread per-route configuration through to Connector::publish without changing the publish signature.

Only the protocol-agnostic timeout_ms is lifted into the typed field; every other key is passed through verbatim in protocol_options for the connector to interpret with its own defaults.

Trait Implementations

impl Clone for ConnectorConfig

fn clone(&self) -> ConnectorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectorConfig

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

Formats the value using the given formatter.

impl Default for ConnectorConfig

fn default() -> Self

Returns the “default value” for a type.