pub struct DsfbObserver { /* private fields */ }Expand description
The DSFB observer for a single residual source channel.
For multi-channel observation (e.g., monitoring latency + throughput +
heartbeat RTT simultaneously), create one DsfbObserver per channel
and correlate their outputs externally.
Implementations§
Source§impl DsfbObserver
impl DsfbObserver
Sourcepub fn new(source: ResidualSource, config: &ObserverConfig) -> Self
pub fn new(source: ResidualSource, config: &ObserverConfig) -> Self
Create a new observer for the given source channel.
Sourcepub fn with_heuristics(
source: ResidualSource,
config: &ObserverConfig,
heuristics: HeuristicsBank,
) -> Self
pub fn with_heuristics( source: ResidualSource, config: &ObserverConfig, heuristics: HeuristicsBank, ) -> Self
Create an observer with a custom heuristics bank.
Sourcepub fn set_envelope(&mut self, envelope: AdmissibilityEnvelope)
pub fn set_envelope(&mut self, envelope: AdmissibilityEnvelope)
Set the admissibility envelope (e.g., after regime classification).
Sourcepub fn set_static_priors(&mut self, static_priors: StaticPriorSet)
pub fn set_static_priors(&mut self, static_priors: StaticPriorSet)
Replace the static priors used during heuristic matching.
Sourcepub fn observe_adapted<T, A>(
&mut self,
adapter: &A,
input: &T,
) -> ObservationResultwhere
A: TelemetryAdapter<T>,
pub fn observe_adapted<T, A>(
&mut self,
adapter: &A,
input: &T,
) -> ObservationResultwhere
A: TelemetryAdapter<T>,
Adapt and observe one application-specific telemetry record.
Sourcepub fn observe(&mut self, sample: &ResidualSample) -> ObservationResult
pub fn observe(&mut self, sample: &ResidualSample) -> ObservationResult
Process a single residual sample and return the full observation result.
This is the primary API. It accepts an immutable reference to a sample and returns a complete structural interpretation.
§Non-Interference
The sample is accepted as &ResidualSample. No mutation of the sample
or its originating system is possible through this API.
Sourcepub fn grammar_state(&self) -> GrammarState
pub fn grammar_state(&self) -> GrammarState
Current grammar state.
Sourcepub fn observation_count(&self) -> u64
pub fn observation_count(&self) -> u64
Total observations processed.
Sourcepub fn audit_trace(&self) -> &AuditTrace
pub fn audit_trace(&self) -> &AuditTrace
Reference to the audit trace.
Sourcepub fn current_episode(&self) -> Option<&Episode>
pub fn current_episode(&self) -> Option<&Episode>
Current open episode, if any.
Sourcepub fn source(&self) -> ResidualSource
pub fn source(&self) -> ResidualSource
Source channel this observer tracks.