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 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).