Crate faucet_source_mssql 

faucet-source-mssql

Microsoft SQL Server query source for the faucet-stream ecosystem, built on tiberius + bb8-tiberius.

Runs parameterized SQL, streams rows as JSON StreamPages through a connection pool, and supports incremental replication via a tracking column (see MssqlReplication). Mirrors the faucet-source-postgres / mysql / sqlite query sources.

let cfg = MssqlSourceConfig::new(
    "mssql://sa:Str0ng%40Pass@localhost:1433/sales",
    "SELECT id, email, updated_at FROM dbo.users",
);
let source = MssqlSource::new(cfg).await?;

Structs

MssqlConnectionConfig

Shared connection configuration for the MSSQL source and sink.

MssqlSource

Microsoft SQL Server query source.

MssqlSourceConfig

Configuration for MssqlSource.

MssqlTls

TLS configuration for an MSSQL connection.

Enums

MssqlReplication

How the source replicates rows across runs.

MssqlTlsMode

MSSQL encryption mode.