pub struct StreamMetrics {
pub items_processed: u64,
pub buffer_size: usize,
pub avg_latency: Duration,
pub throughput: f64,
}Expand description
Stream-specific metrics
Fields§
§items_processed: u64Items processed
buffer_size: usizeCurrent buffer size
avg_latency: DurationAverage processing latency
throughput: f64Throughput
Trait Implementations§
Source§impl Clone for StreamMetrics
impl Clone for StreamMetrics
Source§fn clone(&self) -> StreamMetrics
fn clone(&self) -> StreamMetrics
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 moreAuto Trait Implementations§
impl Freeze for StreamMetrics
impl RefUnwindSafe for StreamMetrics
impl Send for StreamMetrics
impl Sync for StreamMetrics
impl Unpin for StreamMetrics
impl UnwindSafe for StreamMetrics
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> 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