pub struct PipelineStats {
pub events_processed: usize,
pub events_success: usize,
pub events_failed: usize,
pub events_filtered: usize,
pub avg_processing_ms: f64,
pub patches_generated: usize,
pub nodes_added: usize,
pub edges_added: usize,
pub nodes_removed: usize,
pub edges_removed: usize,
}
Expand description
Pipeline statistics
Fields§
§events_processed: usize
Total events processed
events_success: usize
Events processed successfully
events_failed: usize
Events that failed processing
events_filtered: usize
Events that were filtered out
avg_processing_ms: f64
Average processing time in milliseconds
patches_generated: usize
Total patches generated
nodes_added: usize
Total nodes added
edges_added: usize
Total edges added
nodes_removed: usize
Total nodes removed
edges_removed: usize
Total edges removed
Implementations§
Source§impl PipelineStats
impl PipelineStats
Sourcepub fn update(&mut self, event: &PipelineEvent, success: bool)
pub fn update(&mut self, event: &PipelineEvent, success: bool)
Update statistics with a new event
Sourcepub fn success_rate(&self) -> f64
pub fn success_rate(&self) -> f64
Calculate success rate as percentage
Sourcepub fn events_per_second(&self, duration_secs: f64) -> f64
pub fn events_per_second(&self, duration_secs: f64) -> f64
Calculate events per second
Trait Implementations§
Source§impl Clone for PipelineStats
impl Clone for PipelineStats
Source§fn clone(&self) -> PipelineStats
fn clone(&self) -> PipelineStats
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 PipelineStats
impl Debug for PipelineStats
Source§impl Default for PipelineStats
impl Default for PipelineStats
Source§fn default() -> PipelineStats
fn default() -> PipelineStats
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for PipelineStats
impl RefUnwindSafe for PipelineStats
impl Send for PipelineStats
impl Sync for PipelineStats
impl Unpin for PipelineStats
impl UnwindSafe for PipelineStats
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