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§