pub struct MultiChannelObserver { /* private fields */ }Expand description
Multi-channel observer that tracks multiple residual sources simultaneously.
Provides a unified interface for observing all telemetry channels of a distributed system and correlating their structural interpretations.
Implementations§
Source§impl MultiChannelObserver
impl MultiChannelObserver
Sourcepub fn add_channel(
&mut self,
source: ResidualSource,
config: &ObserverConfig,
) -> usize
pub fn add_channel( &mut self, source: ResidualSource, config: &ObserverConfig, ) -> usize
Add an observer for a new source channel. Returns the channel index.
§Panics
Panics if 16 channels are already configured.
Sourcepub fn observe(
&mut self,
channel: usize,
sample: &ResidualSample,
) -> Option<ObservationResult>
pub fn observe( &mut self, channel: usize, sample: &ResidualSample, ) -> Option<ObservationResult>
Observe a sample on a specific channel.
Sourcepub fn channel_state(&self, channel: usize) -> Option<GrammarState>
pub fn channel_state(&self, channel: usize) -> Option<GrammarState>
Get the grammar state of a specific channel.
Sourcepub fn active_channels(&self) -> usize
pub fn active_channels(&self) -> usize
Number of active channels.
Sourcepub fn any_anomalous(&self) -> bool
pub fn any_anomalous(&self) -> bool
Check if ANY channel is in Boundary or Violation state.
Sourcepub fn worst_state(&self) -> GrammarState
pub fn worst_state(&self) -> GrammarState
Collect the worst grammar state across all channels.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for MultiChannelObserver
impl RefUnwindSafe for MultiChannelObserver
impl Send for MultiChannelObserver
impl Sync for MultiChannelObserver
impl Unpin for MultiChannelObserver
impl UnsafeUnpin for MultiChannelObserver
impl UnwindSafe for MultiChannelObserver
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