risingwave_common_metrics::monitor

Function monitor_connector

source
pub fn monitor_connector<C>(
    connector: C,
    connection_type: impl Into<String>,
) -> MonitoredConnection<C, MonitorNewConnectionImpl>