Struct ConnectorRegistry 

pub struct ConnectorRegistry { /* private fields */ }

Re-export the connector registry for custom connector registration. Registry of available connector implementations.

Connectors register themselves with a factory function that creates new instances. The runtime uses the registry to instantiate connectors based on the connector property in the configuration.

Example

use laminar_connectors::registry::ConnectorRegistry;

let mut registry = ConnectorRegistry::new();
registry.register_source("kafka", info, Arc::new(|| Box::new(KafkaSource::new())));

let connector = registry.create_source("kafka", &config)?;

Implementations

impl ConnectorRegistry

pub fn new() -> ConnectorRegistry

Creates a new empty registry.

pub fn register_source( &self, name: impl Into<String>, info: ConnectorInfo, factory: Arc<dyn Fn() -> Box<dyn SourceConnector> + Sync + Send>, )

Registers a source connector factory.

pub fn register_sink( &self, name: impl Into<String>, info: ConnectorInfo, factory: Arc<dyn Fn() -> Box<dyn SinkConnector> + Sync + Send>, )

Registers a sink connector factory.

pub fn create_source( &self, config: &ConnectorConfig, ) -> Result<Box<dyn SourceConnector>, ConnectorError>

Creates a new source connector instance.

The connector type is determined by config.connector_type().

Errors

Returns ConnectorError::ConfigurationError if the connector type is not registered.

The factory creates a default-configured connector. The caller must subsequently call open(config) to forward WITH clause properties.

pub fn create_sink( &self, config: &ConnectorConfig, ) -> Result<Box<dyn SinkConnector>, ConnectorError>

Creates a new sink connector instance.

The connector type is determined by config.connector_type().

Errors

Returns ConnectorError::ConfigurationError if the connector type is not registered.

pub fn register_table_source( &self, name: impl Into<String>, info: ConnectorInfo, factory: Arc<dyn Fn(&ConnectorConfig) -> Result<Box<dyn ReferenceTableSource>, ConnectorError> + Sync + Send>, )

Registers a reference table source factory.

pub fn create_table_source( &self, config: &ConnectorConfig, ) -> Result<Box<dyn ReferenceTableSource>, ConnectorError>

Creates a new reference table source instance.

The connector type is determined by config.connector_type().

Errors

Returns ConnectorError::ConfigurationError if the connector type is not registered as a table source.

pub fn list_table_sources(&self) -> Vec<String>

Lists all registered table source connector names.

pub fn source_info(&self, name: &str) -> Option<ConnectorInfo>

Returns information about a registered source connector.

pub fn sink_info(&self, name: &str) -> Option<ConnectorInfo>

Returns information about a registered sink connector.

pub fn list_sources(&self) -> Vec<String>

Lists all registered source connector names.

pub fn list_sinks(&self) -> Vec<String>

Lists all registered sink connector names.

pub fn create_deserializer( &self, format: &str, ) -> Result<Box<dyn RecordDeserializer>, ConnectorError>

Creates a deserializer for the given format string.

Errors

Returns ConnectorError::Serde if the format is not supported.

pub fn create_serializer( &self, format: &str, ) -> Result<Box<dyn RecordSerializer>, ConnectorError>

Creates a serializer for the given format string.

Errors

Returns ConnectorError::Serde if the format is not supported.

Trait Implementations

impl Clone for ConnectorRegistry

fn clone(&self) -> ConnectorRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectorRegistry

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

Formats the value using the given formatter.

impl Default for ConnectorRegistry

fn default() -> ConnectorRegistry

Returns the “default value” for a type.