risingwave_common_metrics::monitor::connection

Trait MonitorNewConnection

source 
pub trait MonitorNewConnection {
    type ConnectionMonitor: MonitorAsyncReadWrite;

    // Required methods
    fn new_connection_monitor(
        &self,
        endpoint: String,
    ) -> Self::ConnectionMonitor;
    fn on_err(&self, endpoint: String);
}

Required Associated Types§

source

type ConnectionMonitor: MonitorAsyncReadWrite

Required Methods§

source

fn new_connection_monitor(&self, endpoint: String) -> Self::ConnectionMonitor

source

fn on_err(&self, endpoint: String)

Implementors§