Module registry 

Feature-gated dispatch from a string type to a concrete connector.

Every arm in this file is guarded by the matching source-* / sink-* Cargo feature so users can build a slim binary with just the connectors they need. The string keys here are the public contract of the CLI’s type: field in YAML/JSON pipeline configs.

Functions

build_sink

Build a Sink trait object from a (kind, config) pair. When the config carries auth: { ref: <name> }, the named provider is resolved from auth (the catalog) and injected into the connector.

build_source

Build a Source trait object from a (kind, config) pair. When the config carries auth: { ref: <name> }, the named provider is resolved from auth (the catalog) and injected into the connector.

sink_descriptions

One-line summary of every compiled-in sink connector. Used by faucet list.

sink_exists

Check if a sink kind is registered (not unknown or disabled by feature gate).

sink_kinds

Names of every compiled-in sink connector.

sink_schema

Return the JSON Schema for the named sink’s config struct.

source_descriptions

One-line summary of every compiled-in source connector. Used by faucet list.

source_exists

Check if a source kind is registered (not unknown or disabled by feature gate).

source_kinds

Names of every compiled-in source connector.

source_schema

Return the JSON Schema for the named source’s config struct.