Struct FaultInjector 

pub struct FaultInjector { /* private fields */ }

Fault injector for testing resilience scenarios.

Thread-safe structure that can be shared across provider and tests to inject faults dynamically during test execution.

Implementations

impl FaultInjector

pub fn new() -> Self

Create a new fault injector with no faults enabled.

pub fn disable_notifier(&self)

Disable the notifier - prevents it from being spawned.

When called before provider creation, the notifier thread will not start, simulating a notifier failure scenario.

pub fn is_notifier_disabled(&self) -> bool

Check if the notifier is disabled.

pub fn set_notifier_should_panic(&self, should_panic: bool)

Set whether the notifier should panic on next iteration.

pub fn should_notifier_panic(&self) -> bool

Check if the notifier should panic.

pub fn set_refresh_delay(&self, delay: Duration)

Set artificial delay for refresh queries (simulates slow database).

pub fn get_refresh_delay(&self) -> Duration

Get the current refresh delay.

pub fn set_refresh_should_error(&self, should_error: bool)

Set whether the next refresh query should return an error.

pub fn should_refresh_error(&self) -> bool

Check and consume the refresh error flag.

pub fn trigger_reconnect(&self)

Force the notifier to reconnect (simulates connection drop).

pub fn should_reconnect(&self) -> bool

Check and consume the reconnect flag.

pub fn set_clock_skew(&self, skew: Duration)

Set clock skew offset in milliseconds.

Positive values simulate a clock that is ahead (future timestamps). Negative values simulate a clock that is behind (past timestamps).

This offset is added to all now_millis() calculations in the provider, allowing simulation of clock drift between nodes.

Example

use duroxide_pg_opt::FaultInjector;
use std::time::Duration;

let fi = FaultInjector::new();
// Simulate clock 500ms ahead
fi.set_clock_skew(Duration::from_millis(500));

// Simulate clock 200ms behind
fi.set_clock_skew_signed(-200);

pub fn set_clock_skew_signed(&self, skew_ms: i64)

Set clock skew offset in milliseconds (signed).

Positive values simulate a clock that is ahead. Negative values simulate a clock that is behind.

pub fn get_clock_skew_ms(&self) -> i64

Get the current clock skew offset in milliseconds.

pub fn clear_clock_skew(&self)

Clear the clock skew (reset to 0).

Trait Implementations

impl Debug for FaultInjector

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

Formats the value using the given formatter.

impl Default for FaultInjector

fn default() -> FaultInjector

Returns the “default value” for a type.