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 URL with protocol, host, port, and credentials

Supports multiple protocol schemes:

• MQTT: mqtt://host:port, mqtts://host:port
• Kafka: kafka://broker1:port,broker2:port/topic
• HTTP: http://host:port/path, https://host:port/path
• WebSocket: ws://host:port/path, wss://host:port/path

Fields

scheme: String

Protocol scheme (mqtt, mqtts, kafka, http, https, ws, wss)

host: String

Host or comma-separated list of hosts (for Kafka)

port: Option<u16>

Port number (optional, protocol-specific defaults)

path: Option<String>

Path component (for HTTP/WebSocket)

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)
• kafka://broker1:9092,broker2:9092/topic
• http://host:port/path
• https://host:port/path?key=value
• ws://host:port/mqtt (WebSocket)
• wss://host:port/mqtt (WebSocket Secure)

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

pub fn resource_id(&self) -> String

Returns the resource identifier for protocols where the URL specifies a topic/key

This is designed for the simplified connector model where each connector manages a single broker/server connection, and URLs only specify the resource (topic, key, path).

Examples

• mqtt://commands/temperature → "commands/temperature" (topic)
• mqtt://sensors/temp → "sensors/temp" (topic)
• kafka://events → "events" (topic)

The format is scheme://resource where resource = host + path combined.

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ConnectorUrl