pub struct WorkerPoolMetrics {
pub active_workers: usize,
pub idle_workers: usize,
pub queue_depth: usize,
pub events_processed: u64,
pub events_dropped: u64,
pub avg_latency_us: f64,
pub p99_latency_us: f64,
}Expand description
Metrics for a worker pool
Fields§
§active_workers: usizeNumber of currently active (processing) workers
idle_workers: usizeNumber of idle workers
queue_depth: usizeCurrent total queue depth across all workers
events_processed: u64Total events processed
events_dropped: u64Events dropped due to backpressure
avg_latency_us: f64Average processing latency in microseconds
p99_latency_us: f6499th percentile latency in microseconds
Trait Implementations§
Source§impl Clone for WorkerPoolMetrics
impl Clone for WorkerPoolMetrics
Source§fn clone(&self) -> WorkerPoolMetrics
fn clone(&self) -> WorkerPoolMetrics
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 Debug for WorkerPoolMetrics
impl Debug for WorkerPoolMetrics
Source§impl Default for WorkerPoolMetrics
impl Default for WorkerPoolMetrics
Source§fn default() -> WorkerPoolMetrics
fn default() -> WorkerPoolMetrics
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for WorkerPoolMetrics
impl RefUnwindSafe for WorkerPoolMetrics
impl Send for WorkerPoolMetrics
impl Sync for WorkerPoolMetrics
impl Unpin for WorkerPoolMetrics
impl UnsafeUnpin for WorkerPoolMetrics
impl UnwindSafe for WorkerPoolMetrics
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§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