Struct MysqlSource 

pub struct MysqlSource { /* private fields */ }

Implementations

impl MysqlSource

pub fn from_pool(pool: Pool) -> Self

Build a source from an existing pool: the single place that detects the proxy kind, warns once, and wraps the pool. The connect* entry points all funnel through here (also handy in tests that share the pool for post-export state inspection).

pub fn connect(url: &str) -> Result<Self>

Connect with no transport security (legacy path).

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

Connect honoring the user’s TlsConfig.

pub fn proxy_kind(&self) -> MysqlProxyKind

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

#[allow(dead_code)] covers the binary compilation unit; the lib + integration tests reference this through the rivet::source::mysql public surface.

Trait Implementations

impl Source for MysqlSource

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

Governor pressure proxy (Epic 18 C1): the same monotonic extraction-pressure sum the adaptive batch loop samples (Created_tmp_disk_tables + Innodb_buffer_pool_wait_free). Rising between samples means the extraction is spilling a temp table to disk or stalling on buffer-pool memory — the MySQL analogue of PG temp_bytes.

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.