Struct ConnectorRegistry 

pub struct ConnectorRegistry { /* private fields */ }

Re-export the connector registry for custom connector registration. Registry of available connector implementations. Connectors register a factory per type string; the runtime looks up by the connector property in CREATE SOURCE/SINK DDL.

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(Option<&Registry>) -> 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(Option<&Registry>) -> Box<dyn SinkConnector> + Sync + Send>, )

Registers a sink connector factory.

pub async fn default_source_schema( &self, connector_type: &str, properties: &HashMap<String, String>, ) -> Option<Arc<Schema>>

Run a connector’s discover_schema against the given properties and return the resulting Arrow schema. None means the connector type is unknown or discovery produced no fields.

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

Creates a new source connector instance.

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

If a prometheus::Registry is provided, the connector will register its metrics on it so they appear in the scrape output.

Errors

Returns ConnectorError::ConfigurationError if not registered.

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

Creates a new sink connector instance.

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

If a prometheus::Registry is provided, the connector will register its metrics on it so they appear in the scrape output.

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 register_lookup_source( &self, name: impl Into<String>, factory: Arc<dyn LookupSourceFactory>, )

Registers a lookup source factory for on-demand/partial cache mode.

pub async fn create_lookup_source( &self, config: ConnectorConfig, ) -> Option<Result<Arc<dyn LookupSourceDyn>, ConnectorError>>

Creates a lookup source for on-demand cache-miss fallback.

Returns None if no lookup source factory is registered for the given connector type.

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.