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.

sink_supported_write_modes

Write modes each sink kind supports. Kept in sync with each sink’s Sink::supported_write_modes() override.

sink_supports_idempotent_writes

Sink connector kinds that can durably commit a token atomically with data. Mirrors Sink::supports_idempotent_writes overrides — keep in sync when a new sink opts in.

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.

source_supports_exactly_once

Source connector kinds that deterministically replay (exactly-once-capable). Mirrors Source::supports_exactly_once overrides — keep in sync when a new source opts in. See docs/superpowers/plans/2026-06-09-exactly-once-delivery.md.