risingwave_common_metrics::monitor::connection

Function monitor_connector

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