Enum MysqlProxyKind 

pub enum MysqlProxyKind {
    Direct,
    ProxySql,
    MaxScale,
    Multiplexed,
}

What the MySQL connection is actually talking to.

Used to:

• decide which warning (if any) to print at connect time,
• tag the executing query (connection=...) debug log so operators can distinguish direct vs proxied traffic when reading logs after the fact.

Detection happens once at connect time via [detect_mysql_proxy_kind].

pub for integration-test reachability via MysqlSource::proxy_kind(); same “no external API contract” disclaimer applies as for the rest of rivet::source::mysql::*.

Variants

Direct

Direct connection to a MySQL server — no proxy detected.

ProxySql

ProxySQL: detected via either the @@version_comment signature or @@proxy_version (a ProxySQL-only system variable).

MaxScale

MariaDB MaxScale: detected via @@version_comment containing “maxscale”. MaxScale’s readwritesplit and readconnroute routers do not multiplex by default but they can still rewrite or block queries — worth surfacing to the operator.

Multiplexed

An unknown transaction-mode multiplexer: detected because CONNECTION_ID() returned different values across two consecutive queries on the same mysql::Conn. This catches in-house balancers, HAProxy-with-MySQL-mode setups, and ProxySQL/MaxScale instances that hide their banner.

False negatives are possible when the proxy’s backend pool_size is 1 (the same physical backend is always reused).

Implementations

impl MysqlProxyKind

pub fn is_proxy(self) -> bool

True for any non-direct connection (is_proxy() == false only for MysqlProxyKind::Direct).

#[allow(dead_code)] because the binary compilation unit (which re-declares mod source) does not reference this; the lib + tests do. Same pattern as MysqlSource::from_pool.

pub fn log_label(self) -> &'static str

Stable label for the executing query (connection=...) debug log. Keep this terse and stable: external log parsers grep on these strings.

Trait Implementations

impl Clone for MysqlProxyKind

fn clone(&self) -> MysqlProxyKind

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MysqlProxyKind

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for MysqlProxyKind

fn eq(&self, other: &MysqlProxyKind) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for MysqlProxyKind

impl Eq for MysqlProxyKind

impl StructuralPartialEq for MysqlProxyKind