Struct ConnectorConfig 

pub struct ConnectorConfig { /* private fields */ }

Configuration for a connector instance.

Connectors receive their configuration as a string key-value map, typically parsed from SQL WITH (...) clauses or programmatic config.

Implementations

impl ConnectorConfig

pub fn new(connector_type: impl Into<String>) -> Self

Creates a new connector config with the given type.

pub fn with_properties( connector_type: impl Into<String>, properties: HashMap<String, String>, ) -> Self

Creates a config from existing properties.

pub fn connector_type(&self) -> &str

Returns the connector type identifier.

pub fn set(&mut self, key: impl Into<String>, value: impl Into<String>)

Sets a configuration property.

pub fn get(&self, key: &str) -> Option<&str>

Gets a configuration property.

pub fn require(&self, key: &str) -> Result<&str, ConnectorError>

Gets a required configuration property, returning an error if missing.

Errors

Returns ConnectorError::MissingConfig if the key is not set.

pub fn get_parsed<T: FromStr>( &self, key: &str, ) -> Result<Option<T>, ConnectorError>

where T::Err: Display,

Gets a property parsed as the given type.

Errors

Returns ConnectorError::ConfigurationError if the value cannot be parsed.

pub fn require_parsed<T: FromStr>(&self, key: &str) -> Result<T, ConnectorError>

where T::Err: Display,

Gets a required property parsed as the given type.

Errors

Returns ConnectorError::MissingConfig if the key is missing, or ConnectorError::ConfigurationError if parsing fails.

pub fn properties(&self) -> &HashMap<String, String>

Returns all properties as a reference.

pub fn properties_with_prefix(&self, prefix: &str) -> HashMap<String, String>

Returns properties with a given prefix, with the prefix stripped.

pub fn arrow_schema(&self) -> Option<SchemaRef>

Returns the SQL-defined Arrow schema passed via _arrow_schema, or None if absent or unparseable.

The compact format is "col1:Type1,col2:Type2,..." as produced by encode_arrow_schema in laminar-db.

Note: This method re-parses the schema string on each call. Cache the result if you need it in a hot loop.

pub fn validate(&self, specs: &[ConfigKeySpec]) -> Result<(), ConnectorError>

Validates the configuration against a set of key specifications.

Errors

Returns ConnectorError::MissingConfig for missing required keys, or ConnectorError::ConfigurationError for invalid values.

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() -> ConnectorConfig

Returns the “default value” for a type.