pub struct BackpressureMonitor { /* private fields */ }Expand description
Backpressure monitor tracking system resource utilization
Implementations§
Source§impl BackpressureMonitor
impl BackpressureMonitor
pub fn new(config: BackpressureConfig) -> Self
Sourcepub fn set_queue_depth(&self, depth: usize)
pub fn set_queue_depth(&self, depth: usize)
Update queue depth metric
Sourcepub fn increment_queue_depth(&self)
pub fn increment_queue_depth(&self)
Increment queue depth
Sourcepub fn decrement_queue_depth(&self)
pub fn decrement_queue_depth(&self)
Decrement queue depth
Sourcepub fn set_pending_io(&self, count: usize)
pub fn set_pending_io(&self, count: usize)
Update pending I/O count
Sourcepub fn set_memory_usage(&self, bytes: u64)
pub fn set_memory_usage(&self, bytes: u64)
Update memory usage
Sourcepub fn level(&self) -> BackpressureLevel
pub fn level(&self) -> BackpressureLevel
Get current backpressure level
Sourcepub fn snapshot(&self) -> BackpressureSnapshot
pub fn snapshot(&self) -> BackpressureSnapshot
Get current metrics snapshot
Sourcepub fn should_sample(&self) -> bool
pub fn should_sample(&self) -> bool
Should we sample metrics now? (lock-free implementation)
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for BackpressureMonitor
impl RefUnwindSafe for BackpressureMonitor
impl Send for BackpressureMonitor
impl Sync for BackpressureMonitor
impl Unpin for BackpressureMonitor
impl UnsafeUnpin for BackpressureMonitor
impl UnwindSafe for BackpressureMonitor
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