Crate faucet_sink_mssql 

faucet-sink-mssql

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

Inserts records via parameterized multi-row INSERT statements with auto-mapped columns or a single JSON column, mirroring faucet-sink-postgres / mysql / sqlite. Multi-row INSERTs auto-split to stay within MSSQL’s 2100-parameter limit, batches are transaction-wrapped, and per-row failures are isolated for DLQ routing.

let cfg = MssqlSinkConfig::new(
    "mssql://sa:Str0ng%40Pass@localhost:1433/sales",
    "dbo.events",
);
let sink = MssqlSink::new(cfg).await?;

Structs

MssqlConnectionConfig

Shared connection configuration for the MSSQL source and sink.

MssqlSink

Microsoft SQL Server sink.

MssqlSinkConfig

Configuration for MssqlSink.

MssqlTls

TLS configuration for an MSSQL connection.

Enums

MssqlColumnMapping

How records map onto table columns.

MssqlTlsMode

MSSQL encryption mode.

OnUnknownField

What to do with record keys that don’t match a table column (auto_columns).

Constants

DESCRIPTOR

The connector’s static descriptor (RFC 0013): its capabilities, answered from config alone.