risingwave_common_metrics::monitor::connection

Trait MonitorAsyncReadWrite

source
pub trait MonitorAsyncReadWrite {
    // Provided methods
    fn on_read(&mut self, _size: usize) { ... }
    fn on_eof(&mut self) { ... }
    fn on_read_err(&mut self, _err: &Error) { ... }
    fn on_write(&mut self, _size: usize) { ... }
    fn on_flush(&mut self) { ... }
    fn on_shutdown(&mut self) { ... }
    fn on_write_err(&mut self, _err: &Error) { ... }
}

Provided Methods§

source

fn on_read(&mut self, _size: usize)

source

fn on_eof(&mut self)

source

fn on_read_err(&mut self, _err: &Error)

source

fn on_write(&mut self, _size: usize)

source

fn on_flush(&mut self)

source

fn on_shutdown(&mut self)

source

fn on_write_err(&mut self, _err: &Error)

Implementations on Foreign Types§

source§

impl<'a, T: 'a + MonitorAsyncReadWrite + ?Sized> MonitorAsyncReadWrite for &'a mut T

source§

fn on_read(&mut self, _size: usize)

source§

fn on_eof(&mut self)

source§

fn on_read_err(&mut self, _err: &Error)

source§

fn on_write(&mut self, _size: usize)

source§

fn on_flush(&mut self)

source§

fn on_shutdown(&mut self)

source§

fn on_write_err(&mut self, _err: &Error)

Implementors§