Skip to main content

FlowMetrics

ringkernel_core::backpressure

Struct FlowMetrics

pub struct FlowMetrics {
    pub credits_granted: AtomicU64,
    pub credits_consumed: AtomicU64,
    pub backpressure_events: AtomicU64,
    pub dlq_routed: AtomicU64,
    pub dropped: AtomicU64,
    pub high_water_signals: AtomicU64,
    pub low_water_signals: AtomicU64,
}

Expand description

Flow control metrics.

Fields§

§credits_granted: AtomicU64

Total credits granted.

§credits_consumed: AtomicU64

Total credits consumed (messages sent).

§backpressure_events: AtomicU64

Times producer was blocked (credits exhausted).

§dlq_routed: AtomicU64

Messages routed to DLQ due to overflow.

§dropped: AtomicU64

Messages dropped silently.

§high_water_signals: AtomicU64

High water signals emitted.

§low_water_signals: AtomicU64

Low water signals emitted.

Auto Trait Implementations§

impl !Freeze for FlowMetrics

impl RefUnwindSafe for FlowMetrics

impl Send for FlowMetrics

impl Sync for FlowMetrics

impl Unpin for FlowMetrics

impl UnsafeUnpin for FlowMetrics

impl UnwindSafe for FlowMetrics

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> ArchivePointee for T

type ArchivedMetadata = ()

The archived version of the pointer metadata for this type.

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

Converts some archived metadata to the pointer metadata for itself.

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<F, W, T, D> Deserialize<With<T, W>, D> for F
where W: DeserializeWith<F, T, D>, D: Fallible + ?Sized, F: ?Sized,

fn deserialize( &self, deserializer: &mut D, ) -> Result<With<T, W>, <D as Fallible>::Error>

Deserializes using the given deserializer

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

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

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> LayoutRaw for T

fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>

Gets the layout of the type.

impl<T> Pointee for T

type Metadata = ()

The type for metadata in pointers and references to Self.

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<T> WithSubscriber for T

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more