Crate faucet_source_duckdb 

faucet-source-duckdb

DuckDB query source connector for the faucet-stream ecosystem.

Opens a DuckDB database (a file, or in-memory), executes a configurable SQL query, and streams rows as serde_json::Value records with bounded memory. DuckDB is the de-facto embedded analytics engine; this connector mirrors the faucet-source-sqlite query source.

Re-exports

pub use config::DuckdbSourceConfig;

pub use stream::DuckdbSource;

Modules

config

DuckDB source configuration.

stream

DuckDB source implementation — the one module that performs I/O.

Enums

FaucetError

All possible errors returned by faucet-stream.

Traits

Source

A source fetches records from an external system.