pub struct StreamHealthMonitor { /* private fields */ }Expand description
Monitors stream health with configurable thresholds.
Accepts metric updates from the stream pipeline and evaluates them against configured thresholds to produce health alerts.
Implementations§
Source§impl StreamHealthMonitor
impl StreamHealthMonitor
Sourcepub fn new(config: HealthMonitorConfig) -> Self
pub fn new(config: HealthMonitorConfig) -> Self
Creates a new health monitor with the given configuration.
Sourcepub fn record_metric(&self, metric_name: &str, value: f64) -> Vec<HealthAlert>
pub fn record_metric(&self, metric_name: &str, value: f64) -> Vec<HealthAlert>
Records a new metric value and evaluates thresholds.
Returns any new alerts that were raised.
Sourcepub fn snapshot(&self) -> HealthSnapshot
pub fn snapshot(&self) -> HealthSnapshot
Returns the current health snapshot.
Sourcepub fn current_metric(&self, name: &str) -> Option<f64>
pub fn current_metric(&self, name: &str) -> Option<f64>
Returns current metric value for a named metric, if present.
Sourcepub fn total_alerts_raised(&self) -> u64
pub fn total_alerts_raised(&self) -> u64
Returns the total number of alerts ever raised.
Auto Trait Implementations§
impl Freeze for StreamHealthMonitor
impl !RefUnwindSafe for StreamHealthMonitor
impl Send for StreamHealthMonitor
impl Sync for StreamHealthMonitor
impl Unpin for StreamHealthMonitor
impl UnsafeUnpin for StreamHealthMonitor
impl !UnwindSafe for StreamHealthMonitor
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> 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 moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
Source§fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
The inverse inclusion map: attempts to construct
self from the equivalent element of its
superset. Read moreSource§fn is_in_subset(&self) -> bool
fn is_in_subset(&self) -> bool
Checks if
self is actually part of its subset T (and can be converted to it).Source§fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
Use with care! Same as
self.to_subset but without any property checks. Always succeeds.Source§fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
The inclusion map: converts
self to the equivalent element of its superset.