Struct ConnectorUrl 

pub struct ConnectorUrl {
    pub scheme: String,
    pub host: String,
    pub port: Option<u16>,
    pub path: Option<String>,
    pub username: Option<String>,
    pub password: Option<String>,
    pub query_params: Vec<(String, String)>,
}

Parsed connector endpoint URL with protocol, host, port, and credentials

This is the URL a connector is constructed with (broker/gateway/server endpoint) — record links use the far simpler LinkAddress instead. The parser is scheme-agnostic: any scheme://… URL parses. Connectors in this workspace use e.g.:

• MQTT: mqtt://host:port, mqtts://host:port
• KNX: knx://gateway:3671
• WebSocket: ws://host:port/path, wss://host:port/path

Fields

scheme: String

Protocol scheme (e.g. mqtt, mqtts, knx, ws, wss, uds, serial)

host: String

Host, or a comma-separated host list (preserved verbatim)

port: Option<u16>

Port number (optional, protocol-specific defaults)

path: Option<String>

Path component (optional)

username: Option<String>

Username for authentication (optional)

password: Option<String>

Password for authentication (optional)

query_params: Vec<(String, String)>

Query parameters (optional, parsed from URL)

Implementations

impl ConnectorUrl

pub fn parse(url: &str) -> DbResult<Self>

Parses a connector URL string

Supported Formats

• mqtt://host:port
• mqtt://user:pass@host:port
• mqtts://host:port (TLS)
• knx://gateway:3671
• ws://host:port/path?key=value (WebSocket)
• wss://host:port/path (WebSocket Secure)

Any other scheme://… parses the same way; comma-separated host lists are preserved verbatim in host.

Example

use aimdb_core::connector::ConnectorUrl;

let url = ConnectorUrl::parse("mqtt://user:pass@broker.example.com:1883").unwrap();
assert_eq!(url.scheme, "mqtt");
assert_eq!(url.host, "broker.example.com");
assert_eq!(url.port, Some(1883));
assert_eq!(url.username, Some("user".to_string()));

pub fn default_port(&self) -> Option<u16>

Returns the default port for this protocol scheme

pub fn effective_port(&self) -> Option<u16>

Returns the effective port (explicit or default)

pub fn is_secure(&self) -> bool

Returns true if this is a secure connection (TLS)

pub fn scheme(&self) -> &str

Returns the URL scheme (protocol)

pub fn path(&self) -> &str

Returns the path component, or “/” if not specified

Trait Implementations

impl Clone for ConnectorUrl

fn clone(&self) -> ConnectorUrl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectorUrl

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

Formats the value using the given formatter.

impl Display for ConnectorUrl

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

Formats the value using the given formatter.

impl PartialEq for ConnectorUrl

fn eq(&self, other: &ConnectorUrl) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ConnectorUrl