pub struct PipelineMonitor { /* private fields */ }Expand description
Pipeline execution monitor with real-time metrics collection
Implementations§
Source§impl PipelineMonitor
impl PipelineMonitor
Sourcepub fn new(config: MonitorConfig) -> Self
pub fn new(config: MonitorConfig) -> Self
Create a new pipeline monitor
Sourcepub fn start_execution(
&self,
execution_id: &str,
pipeline_name: &str,
) -> ExecutionHandle
pub fn start_execution( &self, execution_id: &str, pipeline_name: &str, ) -> ExecutionHandle
Start monitoring a pipeline execution
Sourcepub fn record_metric(&self, metric: Metric)
pub fn record_metric(&self, metric: Metric)
Record a metric
Sourcepub fn get_metrics_snapshot(&self) -> MetricsSnapshot
pub fn get_metrics_snapshot(&self) -> MetricsSnapshot
Get current metrics snapshot
Sourcepub fn analyze_performance(&self, pipeline_name: &str) -> PerformanceAnalysis
pub fn analyze_performance(&self, pipeline_name: &str) -> PerformanceAnalysis
Analyze performance trends
Sourcepub fn detect_anomalies(&self, pipeline_name: &str) -> Vec<Anomaly>
pub fn detect_anomalies(&self, pipeline_name: &str) -> Vec<Anomaly>
Detect anomalies in pipeline execution
Sourcepub fn set_baseline(
&mut self,
pipeline_name: &str,
baseline: PerformanceBaseline,
)
pub fn set_baseline( &mut self, pipeline_name: &str, baseline: PerformanceBaseline, )
Set performance baseline for a pipeline
Sourcepub fn get_active_executions(&self) -> Vec<ExecutionContext>
pub fn get_active_executions(&self) -> Vec<ExecutionContext>
Get active execution contexts
Auto Trait Implementations§
impl Freeze for PipelineMonitor
impl RefUnwindSafe for PipelineMonitor
impl Send for PipelineMonitor
impl Sync for PipelineMonitor
impl Unpin for PipelineMonitor
impl UnwindSafe for PipelineMonitor
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> 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