Struct MssqlSource 

pub struct MssqlSource { /* private fields */ }

SQL Server source. Owns the async driver + the runtime that drives it.

pub (not pub(crate)) so integration tests can reach proxy_kind() the same way they reach MysqlSource::proxy_kind(); the rest of the type carries the same “no external API contract” disclaimer as MysqlSource.

Implementations

impl MssqlSource

pub fn connect_with_tls(url: &str, tls: Option<&TlsConfig>) -> Result<Self>

Connect to SQL Server, honouring the shared TlsConfig. url is the resolved sqlserver://user:pass@host:port/db form. A successful return has completed a TLS login handshake and a SELECT 1 round-trip.

pub fn proxy_kind(&self) -> MssqlProxyKind

Expose the proxy classification for diagnostics (preflight, integration tests). Not part of the Source trait — same internal-may-change contract as the rest of rivet::source::mssql::*.

Trait Implementations

impl Drop for MssqlSource

fn drop(&mut self)

Pooler-safe session teardown (Epic 18 B2). rivet never opens a transaction on this connection — every read is an autocommit SELECT, so there is no transaction to leave dangling across the block_on bridge (ADR-0011). The only session state the export mutates is SET LOCK_TIMEOUT; reset it to the SQL Server default (-1, wait indefinitely) before the connection closes so a multiplexed pooler that keeps the backend connection alive cannot hand our non-default LOCK_TIMEOUT to the next session that reuses it.

Best-effort and time-boxed: after a failed read the stream is half-drained and the connection is dying anyway, so the reset (and the physical connection) just goes away; the 2 s cap guarantees Drop can never hang on a wedged connection.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Source for MssqlSource

fn export( &mut self, request: &ExportRequest<'_>, sink: &mut dyn BatchSink, ) -> Result<()>

Execute request.query and stream batches into sink.

fn query_scalar(&mut self, sql: &str) -> Result<Option<String>>

fn type_mappings( &mut self, query: &str, column_overrides: &ColumnOverrides, ) -> Result<Vec<TypeMapping>>

Return TypeMapping for every column in query without fetching rows.

fn sample_pressure(&mut self) -> Option<u64>

Sample a monotonic source-pressure counter for the OPT-2 concurrency governor (pipeline::chunked::exec).