risingwave_common_metrics::monitor::connection

Struct MonitorAsyncReadWriteImpl

pub struct MonitorAsyncReadWriteImpl {
    endpoint: String,
    connection_type: String,
    unreported_read_rate: u64,
    read_rate: IntCounter,
    reader_count_guard: IntGauge,
    is_eof: bool,
    unreported_write_rate: u64,
    write_rate: IntCounter,
    writer_count_guard: IntGauge,
    is_shutdown: bool,
    connection_count_guard: IntGauge,
}

Fields§

§endpoint: String§connection_type: String§unreported_read_rate: u64§read_rate: IntCounter§reader_count_guard: IntGauge§is_eof: bool§unreported_write_rate: u64§write_rate: IntCounter§writer_count_guard: IntGauge§is_shutdown: bool§connection_count_guard: IntGauge

Struct MonitorAsyncReadWriteImplCopy item path

Fields§

Implementations§

impl MonitorAsyncReadWriteImpl

pub fn new( endpoint: String, connection_type: String, read_rate: IntCounter, reader_count: IntGauge, write_rate: IntCounter, writer_count: IntGauge, connection_count: IntGauge, ) -> Self

Trait Implementations§

impl Drop for MonitorAsyncReadWriteImpl

fn drop(&mut self)

impl MonitorAsyncReadWrite for MonitorAsyncReadWriteImpl

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_shutdown(&mut self)

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

fn on_flush(&mut self)

Auto Trait Implementations§

impl Freeze for MonitorAsyncReadWriteImpl

impl RefUnwindSafe for MonitorAsyncReadWriteImpl

impl Send for MonitorAsyncReadWriteImpl

impl Sync for MonitorAsyncReadWriteImpl

impl Unpin for MonitorAsyncReadWriteImpl

impl UnwindSafe for MonitorAsyncReadWriteImpl

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<M> MetricVecRelabelExt for M

fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>

fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct MonitorAsyncReadWriteImpl

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,