Struct FlowMetrics
pub struct FlowMetrics {
pub credits_granted: Atomic<u64>,
pub credits_consumed: Atomic<u64>,
pub backpressure_events: Atomic<u64>,
pub dlq_routed: Atomic<u64>,
pub dropped: Atomic<u64>,
pub high_water_signals: Atomic<u64>,
pub low_water_signals: Atomic<u64>,
}Expand description
Flow control metrics.
Fields§
§credits_granted: Atomic<u64>Total credits granted.
credits_consumed: Atomic<u64>Total credits consumed (messages sent).
backpressure_events: Atomic<u64>Times producer was blocked (credits exhausted).
dlq_routed: Atomic<u64>Messages routed to DLQ due to overflow.
dropped: Atomic<u64>Messages dropped silently.
high_water_signals: Atomic<u64>High water signals emitted.
low_water_signals: Atomic<u64>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> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
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
impl<F, W, T, D> Deserialize<With<T, W>, D> for F
§fn deserialize(
&self,
deserializer: &mut D,
) -> Result<With<T, W>, <D as Fallible>::Error>
fn deserialize( &self, deserializer: &mut D, ) -> Result<With<T, W>, <D as Fallible>::Error>
Deserializes using the given deserializer
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Gets the layout of the type.