pub struct QueueSnapshot {Show 14 fields
pub path: Arc<str>,
pub depth: usize,
pub reserved_count: usize,
pub retained_bytes: usize,
pub oldest_age: Option<Duration>,
pub throttled_count: u64,
pub rejected_count: u64,
pub dropped_count: u64,
pub coalesced_count: u64,
pub closed_slow_consumer_count: u64,
pub waiters: usize,
pub wait_count: u64,
pub deadline_exceeded_count: u64,
pub closed: bool,
}Expand description
Represents queue snapshot.
Fields§
§path: Arc<str>The path value.
depth: usizeThe depth value.
reserved_count: usizeThe number of reserved entries.
retained_bytes: usizeThe retained size in bytes.
oldest_age: Option<Duration>The oldest age value.
throttled_count: u64The number of throttled entries.
rejected_count: u64The number of rejected entries.
dropped_count: u64The number of dropped entries.
coalesced_count: u64The number of coalesced entries.
closed_slow_consumer_count: u64The number of closed slow consumer entries.
waiters: usizeThe number of producers currently waiting for admission.
wait_count: u64The cumulative number of producers that waited for admission.
deadline_exceeded_count: u64The number of items returned because their admission deadline elapsed.
closed: boolWhether closed.
Trait Implementations§
Source§impl Clone for QueueSnapshot
impl Clone for QueueSnapshot
Source§impl Debug for QueueSnapshot
impl Debug for QueueSnapshot
impl Eq for QueueSnapshot
Source§impl PartialEq for QueueSnapshot
impl PartialEq for QueueSnapshot
impl StructuralPartialEq for QueueSnapshot
Auto Trait Implementations§
impl Freeze for QueueSnapshot
impl RefUnwindSafe for QueueSnapshot
impl Send for QueueSnapshot
impl Sync for QueueSnapshot
impl Unpin for QueueSnapshot
impl UnsafeUnpin for QueueSnapshot
impl UnwindSafe for QueueSnapshot
Blanket Implementations§
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