Struct ChangeDetector 

pub struct ChangeDetector { /* private fields */ }

Deterministic change-feed detector.

The detector is Copy so it can live in a static configuration struct without a wrapper. The default configuration (ChangeDetector::new) uses the documented defaults — every field has a public constant and every value can be overridden through ChangeDetector::with_thresholds.

Example

use stygian_charon::change_feed::{
    ChangeDeltaInput, ChangeDetector, InMemoryChangeFeedSink, DeltaSeverity, DeltaSource,
};

let detector = ChangeDetector::new();
let sink = InMemoryChangeFeedSink::new();

let deltas = vec![ChangeDeltaInput::new(
    DeltaSource::Canary,
    "example.com",
    0.05,
    DeltaSeverity::Clean,
    "canary blip",
)];

let report = detector.detect(&deltas, &sink);
// A Clean-severity canary blip is the noise
// default — no event is emitted.
assert!(report.noise_targets.iter().any(|t| t == "example.com"));
assert!(sink.is_empty());

Implementations

impl ChangeDetector

pub fn new() -> Self

Build a detector with the default thresholds.

pub const fn with_thresholds(self, thresholds: ChangeFeedThresholds) -> Self

Replace the thresholds.

pub const fn thresholds(&self) -> ChangeFeedThresholds

Current thresholds.

pub fn detect<S: ChangeEventSink + ?Sized>( &self, deltas: &[ChangeDeltaInput], sink: &S, ) -> ChangeFeedReport

Classify a slice of deltas and emit one ChangeEvent per Suspected / Probable target into sink. Returns the full ChangeFeedReport regardless of band — callers can inspect noise_targets / suspected_targets / probable_targets to drive dashboards without parsing events.

Trait Implementations

impl Clone for ChangeDetector

fn clone(&self) -> ChangeDetector

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ChangeDetector

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ChangeDetector

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ChangeDetector

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ChangeDetector

fn eq(&self, other: &ChangeDetector) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for ChangeDetector

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for ChangeDetector

impl StructuralPartialEq for ChangeDetector