Struct AnomalyInjector 

pub struct AnomalyInjector { /* private fields */ }

Main anomaly injection engine.

Implementations

impl AnomalyInjector

pub fn new(config: AnomalyInjectorConfig) -> Self

Creates a new anomaly injector.

pub fn process_entries( &mut self, entries: &mut [JournalEntry], ) -> InjectionBatchResult

Processes a batch of journal entries, potentially injecting anomalies.

pub fn inject_specific( &mut self, entry: &mut JournalEntry, anomaly_type: AnomalyType, ) -> Option<LabeledAnomaly>

Injects a specific anomaly type into an entry.

pub fn create_self_approval( &mut self, entry: &mut JournalEntry, user_id: &str, ) -> Option<LabeledAnomaly>

Creates a self-approval anomaly.

pub fn create_sod_violation( &mut self, entry: &mut JournalEntry, user_id: &str, conflicting_duties: (&str, &str), ) -> Option<LabeledAnomaly>

Creates a segregation of duties violation.

pub fn create_ic_mismatch( &mut self, entry: &mut JournalEntry, matching_company: &str, expected_amount: Decimal, actual_amount: Decimal, ) -> Option<LabeledAnomaly>

Creates an intercompany mismatch anomaly.

pub fn get_labels(&self) -> &[LabeledAnomaly]

Returns all generated labels.

pub fn get_summary(&self) -> AnomalySummary

Returns the anomaly summary.

pub fn get_stats(&self) -> &InjectorStats

Returns injection statistics.

pub fn reset(&mut self)

Clears all labels and resets statistics.

pub fn cluster_count(&self) -> usize

Returns the number of clusters created.

pub fn advance_schemes( &mut self, date: NaiveDate, company_code: &str, ) -> Vec<SchemeAction>

Advances all active fraud schemes by one time step.

Call this method once per simulated day to generate scheme actions. Returns the scheme actions generated for this date.

pub fn maybe_start_scheme( &mut self, date: NaiveDate, company_code: &str, available_users: Vec<String>, available_accounts: Vec<String>, available_counterparties: Vec<String>, ) -> Option<Uuid>

Potentially starts a new fraud scheme based on probabilities.

Call this method periodically (e.g., once per period) to allow new schemes to start based on configured probabilities. Returns the scheme ID if a scheme was started.

pub fn get_near_miss_labels(&self) -> &[NearMissLabel]

Returns all near-miss labels generated.

pub fn get_scheme_actions(&self) -> &[SchemeAction]

Returns all scheme actions generated.

pub fn get_difficulty_distribution( &self, ) -> &HashMap<AnomalyDetectionDifficulty, usize>

Returns the detection difficulty distribution.

pub fn check_behavioral_deviations( &self, entity_id: &str, observation: &Observation, ) -> Vec<BehavioralDeviation>

Checks for behavioral deviations for an entity with an observation.

pub fn get_entity_baseline(&self, entity_id: &str) -> Option<&EntityBaseline>

Gets the baseline for an entity.

pub fn active_scheme_count(&self) -> usize

Returns the number of active schemes.

pub fn has_enhanced_features(&self) -> bool

Returns whether enhanced features are enabled.