pub struct CreditStats<const N: usize> {
pub delivered: [u64; N],
pub dropped_no_credit: [u64; N],
pub dropped_full: [u64; N],
pub detached: [bool; N],
pub detach_count: [u64; N],
pub depth: [u64; N],
/* private fields */
}Expand description
Per-consumer credit stats (router-enforced credits).
Notes:
- For
RouterMode::WorkQueue,dropped_fullis not attributable to a single consumer when the router fails to find any eligible destination; in that case per-consumer drops are best-effort. - If
N > 64, per-consumer masks are not computed and attribution is disabled.
Fields§
§delivered: [u64; N]Per-consumer count of delivered messages.
dropped_no_credit: [u64; N]Per-consumer drops attributable to credit exhaustion.
dropped_full: [u64; N]Per-consumer drops attributable to destination queues being full.
detached: [bool; N]Per-consumer detached state (for CreditPolicy::Detach).
detach_count: [u64; N]Per-consumer number of detach events.
depth: [u64; N]Per-consumer estimated queue depth (tail - head).
This is sampled from shared state and may be stale.
Trait Implementations§
Source§impl<const N: usize> Clone for CreditStats<N>
impl<const N: usize> Clone for CreditStats<N>
Source§fn clone(&self) -> CreditStats<N>
fn clone(&self) -> CreditStats<N>
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl<const N: usize> Debug for CreditStats<N>
impl<const N: usize> Debug for CreditStats<N>
Source§impl<const N: usize> Default for CreditStats<N>
impl<const N: usize> Default for CreditStats<N>
Source§impl<const N: usize> PartialEq for CreditStats<N>
impl<const N: usize> PartialEq for CreditStats<N>
impl<const N: usize> Eq for CreditStats<N>
impl<const N: usize> StructuralPartialEq for CreditStats<N>
Auto Trait Implementations§
impl<const N: usize> Freeze for CreditStats<N>
impl<const N: usize> RefUnwindSafe for CreditStats<N>
impl<const N: usize> Send for CreditStats<N>
impl<const N: usize> Sync for CreditStats<N>
impl<const N: usize> Unpin for CreditStats<N>
impl<const N: usize> UnwindSafe for CreditStats<N>
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